大佬,我用flink sql的形式用cdc,在运行,不报错,也不打印在控制台怎么办? 这个问题,要怎么排查 打印了,用datastream的形式,能读到数据,我要上传jar包,运行到yarn,一直做同步,其实都一样,这个应该不是数据库的问题,因为datastream可以读,DataStream resultStream = tableEnv.toChangelogStream(resultTable);加上这个?
这个问题,要怎么排查,用sql可以直接sql-client执行,没必要嵌套在java里,不好意思,oracle不会哈,盲猜下,你的tableresult转一下?我记得是转成一个其他的就可以输出了,具体忘了 是的,你再把resultstream输出下,此回答整理自钉群“Flink CDC 社区”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。