coffin_fe
2021-10-20 11:44
采纳率: 25%
浏览 75

flink sql 2.12 kafka 双流join 写es b表属性总为null

1单独运行两个流报错数据到es 没问题
2为了确保数据没收到
2.1kafka生产者我循环每30毫秒发一条

img

2.2 另外开一个消费者 看到了数据

img

3代码如下

3.1 sink的sql

img

img

3.2 创建es sink表

img

3.3 kafka流表
a表

img

b表

img

3.4 代码运行无错误

img

3.5 es sink结果

img

请问:我哪写的有问题?

  • 好问题 提建议
  • 收藏

2条回答 默认 最新

  • AMMOHERE 2021-10-21 15:42

    执行sql的时候,把sql打印出来看看

    评论
    解决 无用
    打赏 举报
  • 少林码农 2021-10-23 17:01

    提供相关的表结构和几行数据以及输出你的SQL便于我本地调试,请不要截图,直接复制粘贴

    评论
    解决 无用
    打赏 举报

相关推荐 更多相似问题