目前 1.11 版本中的 tableResult.print 只支持 exactly once 语义,需要配置 checkpoint。
1.12 里准备支持 at least once 语义,用户可以不用配置 checkpoint。目前 pr [1] 正在reivew 。 [1] https://github.com/apache/flink/pull/12867 Best, Godfrey Jingsong Li <jingsongl...@gmail.com> 于2020年7月16日周四 上午11:36写道: > tableResult.print需要有checkpoint > > Best, > Jingsong > > On Thu, Jul 16, 2020 at 11:31 AM amen...@163.com <amen...@163.com> wrote: > > > hi, everyone > > > > 小白在测试flink > > > 1.11新特性新内置的三个connector时,在本地创建图片[1]中的任务并进行数据打印时,控制台只打印了表schema,而没有按内置的datagen > > connector规则产生数据,请问可能是什么原因呢?谢谢解答! > > > > > > [1] https://postimg.cc/PprT9XV6 > > > > best, > > amenhub > > > > > > > > amen...@163.com > > > > > -- > Best, Jingsong Lee >