> On Nov 4, 2022, at 2:34 PM, 左岩 <13520871...@163.com> wrote:
>
> tenv.executeSql("xxx);
> env.execute();
这样使用是不对的，你可以看下这两个方法的java doc
祝好，
Leonard
ql1);
>> >statementSet.addInsertSql(sql2);
>> >TableResult result = statementSet.execute();
>> >result.getJobClient().get().getJobID().toString();
>> >
>> >
>> >或者你把打印的那个任务给去掉，看能否将数据插入到目的的mysql中。
>> >// 查询
>> >tenv.ex
> --------这个任务给去掉
> >
> >
> >
> >yinghua...@163.com
> >
> >发件人： 左岩
> >发送时间： 2022-11-04 14:34
> >收件人： user-zh
> >主题： FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里
> >用FlinkCDC可以读到MySQL变更数据，但是插不到新
ecuteSql("select * from flink_t_stu").print();
>这个任务给去掉
>
>
>
>yinghua...@163.com
>
>发件人： 左岩
>发送时间： 2022-11-04 14:34
>收件人： user-zh
>主题： FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里
>用FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里，两个表都有主键，表结构相同
>代码如下：控制台打印情
用FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里，两个表都有主键，表结构相同
代码如下：控制台打印情况见附件
public static void main(String[] args) throws Exception {
Configuration conf = new Configuration();
conf.setInteger("rest.port", 10041);
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnviro
