Flink作业无Sink能否执行？移除Sink后算子仍运行问题咨询

• Flink数据流的运行机制：Flink作业基于数据流图驱动，只要作业里有Source节点，启动后Source就会持续向管道推送数据，下游算子也会正常处理这些数据。Sink只是负责把最终数据输出到外部存储/系统的终端节点，没有Sink的话，数据经过最后一个算子处理后会被直接丢弃，但整个数据流的处理流程不会中断。

• 作业启动的校验规则：Flink对作业提交的校验仅要求存在至少一个Source节点（无Source的纯计算作业除外），并不强制必须配置Sink。所以移除所有Sink后，作业依然能正常启动运行，不会出现启动失败的情况。

• 性能优化的注意点：你观察到无Sink时算子仍执行的情况，说明这些算子属于Source下游的有效数据流分支。如果要缩短作业处理时长，对于不需要的数据流分支，不能只移除Sink，而是要直接从数据流图里删除对应的算子分支——否则这些算子的计算开销依然会占用集群资源，影响整体处理效率。

内容的提问来源于stack exchange，提问作者André Casimiro