请大家帮忙看一下这句insert into产生的job,是怎么回事?

"lQDPJxymA3PQPmTND8DNC9CwIjdP-LA6c9oECIi13gByAA_3024_4032.jpg 大家有无试过做官网的例子时,job一直running,lQDPJwem5k1UXqTND8DNC9Cw2cgI9gxd8RcECIkU4EByAA_3024_4032.jpg 这句insert into产生的job。看日志没有报错,数据也能从mysql落到elaticsearch了,其实job已经完成。但是flink显示job一直running,是为什么呢?" image.png

展开
收起
滴滴滴~ 2023-03-21 11:51:40 205 分享 版权
1 条回答
写回答
取消 提交回答
  • Cdc就是一直running。 此答案整理自钉群“Flink CDC 社区”

    2023-03-21 16:34:08
    赞同 展开评论

DataWorks基于MaxCompute/Hologres/EMR/CDP等大数据引擎,为数据仓库/数据湖/湖仓一体等解决方案提供统一的全链路大数据开发治理平台。

收录在圈子:
+ 订阅
还有其他疑问?
咨询AI助理