Flink流作业也会有已完成状态吗?有个任务停止后变成了已完成,不应该是已停止吗?
在Flink中,任务具有不同的状态,包括已停止(STOPPED)和已完成(FINISHED)。
已停止(STOPPED):表示任务被显式地停止或由于某种原因而异常终止。当您主动停止任务或任务发生错误时,任务状态将变为已停止。
已完成(FINISHED):表示任务成功完成了其执行。在流处理作业中,这意味着所有输入数据已经处理完毕,并且没有更多的输出结果需要生成。当任务达到流的终点并成功处理了所有数据时,任务状态将变为已完成。
因此,如果您的任务停止后变为已完成状态,而不是已停止状态,则说明该任务已经成功处理了所有输入数据并顺利结束。这通常表示任务已经完成了它需要处理的工作,并且没有进一步的操作需要执行。
"已完成"状态:表示有限流作业已经成功处理完了所有的输入数据,并且所有的结果都已经生成和提交给了sink。
"已停止"状态:表示您将流作业被显式地终止或手动停止了。此回答整理自钉群“实时计算Flink产品交流群”
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。