一个Flink问题,如果设置为tartupOptions.latest(),哪这个参数没有意义啊?

还有一个Flink问题,如果设置为tartupOptions.latest(),每次一次重启都是最新的,哪个参数没有意义啊,比如我十点同步的最新数据,11点停了,12点启动了,哪11-12之间的数据也不会同步吗?

展开
收起
冰激凌甜筒 2023-04-24 14:05:55 267 分享 版权
1 条回答
写回答
取消 提交回答
  • 如果将 startupOptions 设置为 latest(),则该参数将指示 Flink 从最新的已完成检查点恢复作业。这意味着作业将从上次停止的位置继续运行,而不会丢失任何数据。

    但是,如果作业从未运行过,或者没有可用的检查点,则 latest() 参数将不起作用。在这种情况下,作业将从头开始运行。

    因此,只有在作业已经运行过并且存在可用的检查点时,latest() 参数才有意义。

    2024-02-28 17:52:14
    赞同 展开评论

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

还有其他疑问?
咨询AI助理