Flink-1.11内置connector测试问题求解

hi, everyone

小白在测试flink 1.11新特性新内置的三个connector时，在本地创建图片[1]中的任务并进行数据打印时，控制台只打印了表schema，而没有按内置的datagen connector规则产生数据，请问可能是什么原因呢？谢谢解答！


[1] https://postimg.cc/PprT9XV6

best,
amenhub



[hidden email]

[Jingsong Li]

 tableResult.print需要有checkpoint

Best,
Jingsong

On Thu, Jul 16, 2020 at 11:31 AM [hidden email] <[hidden email]> wrote:

> hi, everyone
>
> 小白在测试flink
> 1.11新特性新内置的三个connector时，在本地创建图片[1]中的任务并进行数据打印时，控制台只打印了表schema，而没有按内置的datagen
> connector规则产生数据，请问可能是什么原因呢？谢谢解答！
>
>
> [1] https://postimg.cc/PprT9XV6
>
> best,
> amenhub
>
>
>
> [hidden email]
>

--
Best, Jingsong Lee

[godfrey he]

目前 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 <[hidden email]> 于2020年7月16日周四 上午11:36写道：

>  tableResult.print需要有checkpoint
>
> Best,
> Jingsong
>
> On Thu, Jul 16, 2020 at 11:31 AM [hidden email] <[hidden email]> wrote:
>
> > hi, everyone
> >
> > 小白在测试flink
> >
> 1.11新特性新内置的三个connector时，在本地创建图片[1]中的任务并进行数据打印时，控制台只打印了表schema，而没有按内置的datagen
> > connector规则产生数据，请问可能是什么原因呢？谢谢解答！
> >
> >
> > [1] https://postimg.cc/PprT9XV6
> >
> > best,
> > amenhub
> >
> >
> >
> > [hidden email]
> >
>
>
> --
> Best, Jingsong Lee
>