Flink SQL作业相关问题 Flink SQL作业消费Kafka后sink到es集群,作业执行成功,但未写入数据 问题现象 客户创建Flink SQL作业,消费Kafka后sink到es集群,作业执行成功,但无数据。 原因分析 查看客户作业脚本内容,排查无问题,作业执行成功,出现该问题可能的原因如下: 数据不准确。 数据处理有问题。 处理步骤 1.在Flink UI查看task日志,发现报错中提到json体,基本确定原因为数据格式问题。 2.排查客户实际数据,发现客户Kafka数据存在多层嵌套的复杂json体。