Apache Flink缓存作业吗



我注意到,每次运行一个新作业时,与再次启动它时相比,所花费的时间大约长20%?

如果一个作业多次运行,flink是否会缓存一些结果并重用它们?如果是,我该如何控制?

我想测量一下我的任务运行了多长时间,但每次重新运行它们都比以前快。

如果您使用一些有状态的函数和配置的检查点和保存点,您的工作可能需要一段时间才能从检查点恢复状态。

为了使状态具有容错性,Flink需要检查状态。检查点允许Flink恢复流中的状态和位置,为应用程序提供与无故障执行相同的语义。

有关检查点的更多信息,请点击此处。

监控检查点

相关内容

  • 没有找到相关文章

最新更新