我注意到,每次运行一个新作业时,与再次启动它时相比,所花费的时间大约长20%?
如果一个作业多次运行,flink是否会缓存一些结果并重用它们?如果是,我该如何控制?
我想测量一下我的任务运行了多长时间,但每次重新运行它们都比以前快。
如果您使用一些有状态的函数和配置的检查点和保存点,您的工作可能需要一段时间才能从检查点恢复状态。
为了使状态具有容错性,Flink需要检查状态。检查点允许Flink恢复流中的状态和位置,为应用程序提供与无故障执行相同的语义。
有关检查点的更多信息,请点击此处。
监控检查点