你用的是哪个版本的 cdc，增量部分的数据需要全量的部分读完才能进行。
Best,
Shengkai
左岩 <13520871...@163.com> 于2022年11月4日周五 17:58写道：
>
>
>
>
>
>
>
>
>
> .print(); 去掉也不行，
>
> 跟这个也没有关系（一个tableEnv要执行2个DML），而且现在有一个现象，就是现在改了mysql表数据，flinkcdc得等好久才能读到变化数据，这是什么情况呢
>
>
>
>
>
>
>
>
> 在 2022-11-04 16:52:08，"yinghua...@163.com" 写道：
>
> >
.print(); 去掉也不行，
跟这个也没有关系（一个tableEnv要执行2个DML），而且现在有一个现象，就是现在改了mysql表数据，flinkcdc得等好久才能读到变化数据，这是什么情况呢
在 2022-11-04 16:52:08，"yinghua...@163.com" 写道：
>你这个是在一个tableEnv要执行2个DML，要使用StatementSet保存2个DML语句，在StatementSet上执行exuectute，如下
>StatementSet statementSet = tenv.createStatemen
