我使用flinkcdc的sql形式进行全量同步，4张表，有两张表数据没进去，，id怎么是null呢?
我使用flinkcdc的sql形式进行全量同步，4张表，有两张表数据没进去，看日志，id怎么是null呢?
flinkcdc 整库同步是不是不能用sql形式只能用DataStream API 啊？
flinkcdc 整库同步是不是不能用sql形式只能用DataStream API 啊？
flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ？
flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ？
flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ？
flinkcdc的sql或者是api的方式能增量获取sqlserver2008版本的嘛 ？ cdc mysql 2.3版本为啥老是出现这个问题
用flinkcdc的sql进行同步数据, 开始的时候增删改都是可以的, 但是删除不可以,？
用flinkcdc的sql进行同步数据, 开始的时候增删改都是可以的, 突然就新增编辑可以同步, 但是删除不可以,？
flinkcdc能兼容 SQL Server2008吗？我看官网写2012开始支持的 ，估计是不行.
flinkcdc能兼容 SQL Server2008吗？我看官网写2012开始支持的 ，估计是不行.
大佬们，我目前的场景是flinkcdc 用sql将mongo数据同步到es，有人做过这样的场景吗？
大佬们，我目前的场景是flinkcdc 用sql将mongo数据同步到es，有人做过这样的场景吗？想问一下，在写es的时候，如何指定_id的值呢？
请问Flinkcdc中我用sql语句将数据insert into 到我kafka表怎么避免程序关闭？
请问Flinkcdc中我用sql语句将数据insert into 到我kafka表后，就是t_evn.execute()程序就关闭了，如果后面加了print()，程序就不会关闭，怎么避免程序关闭呢？我直接设置的表环境，也设定了流模式。
请问Flinkcdc中一个sql语句只能创建一个表的cdc？
问题1：请问Flinkcdc中一个sql语句只能创建一个表的cdc？问题2：多个表的话字段怎么定义？
请问flinkcdc中这是啥情况呢？是sql写的有问题吗？
"""-- 定义源表数据结构CREATE TABLE acct ( id INTEGER NOT NULL, ntw_id INTEGER, business_date STRING, amount DECIMAL(20, 4), PRIMARY KEY (id) NOT ENFORCED...
本页面内关键词为智能算法引擎基于机器学习所生成，如有任何问题，可在页面下方点击"联系我们"与我们沟通。
