开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

Flink CDC中我定义了事件时间的watermark为什么在界面上不显示?

"Flink CDC中我定义了事件时间的watermark为什么在界面上不显示?
f1c4a5706b70307c0deb2693ba72d198.png
我用的flinksql 读kafka。
dc5509ce071bdb4eb913ccdcf42bc288.png
a22a947a883621e408da8cc4ddf0a686.png
aab1b0badc4374f946dcebf20c5c7120.png
时间字符串转了long作为watermark,我这个是因为时间戳提取的有问题?"

展开
收起
小易01 2023-08-15 23:52:58 107 0
1 条回答
写回答
取消 提交回答
  • Flink CDC 的事件时间 watermark 默认是基于数据流中事件的 timestamp 生成的,如果没有指定 watermark 生成器,则不会在界面上显示 watermark。

    如果需要在界面上显示 watermark,可以通过以下方式指定 watermark 生成器:

    在 Flink CDC 的配置文件中指定 watermark.generator 属性。
    在 Flink CDC 的代码中创建一个 WatermarkGenerator 对象,并将其注册到 Flink 的配置中。
    以下是一个示例配置:

    指定 watermark 生成器的类名

    watermark.generator = org.apache.flink.streaming.api.watermark.DefaultWatermarkGenerator

    2023-09-22 11:18:22
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载