开发者社区> 问答> 正文

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

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

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

*来自志愿者整理的flink邮件归档

展开
收起
小阿矿 2021-12-06 15:52:08 777 0
1 条回答
写回答
取消 提交回答
  • 目前 1.11 版本中的 tableResult.print 只支持 exactly once 语义,需要配置 checkpoint。

    1.12 里准备支持 at least once 语义,用户可以不用配置 checkpoint。目前 pr [1] 正在reivew 。

    [1] https://github.com/apache/flink/pull/12867*来自志愿者整理的flink邮件归档

    2021-12-06 18:38:49
    赞同 展开评论 打赏
问答地址:
问答排行榜
最热
最新

相关电子书

更多
《基于 Flink 的全新 Pulsar Connector 的设计、开发和使用》 立即下载
Alink:基于Apache Flink的算法平台 立即下载
Apache Flink技术进阶 立即下载