flinksql source是kafka,写也是kafka,我这还没有往kakfa造数据呢?[阿里云实时计算 Flink版]

flinksql source是kafka,写也是kafka,我这还没有往kakfa造数据呢,就一致报这个错误

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. 这种情况可能是由于您的Flink job的输入数据格式与您的Flink job的输出数据格式不匹配导致的。您可以通过Flink Web界面查看Flink job的输入和输出数据格式,以确保它们是正确的。此外,您还可以查看Flink job的日志,以更好地了解Flink job的运行情况。

  2. 您可以参考一下这个,应该有您想要的回答: ——该回答整理自钉群“【③群】Apache Flink China社区”