INFO-实时同步任务数据延迟排查流程

使用场景

使用示例

使用下方 参数算子后 flink 页面打印完整scan 然后变更上游数据 推理是卡在哪个位置

1/ ddl —— map 立即变更 则大概率卡在写入 确认batchinterval是否过长导致下游等待批次时间造成延迟 通过设置规避

pipeline.operator-chaining=false
任务启动时配置flink参数，拆分算子链，单独查看每个算子的输入输出

作者：华柄印