finish状态导致checkpoint不触发,我看了源码,在CheckpointCoordinator.triggerCheckpoint方法有判断:
<http://apache-flink.147419.n8.nabble.com/file/t1014/Dingtalk_20201104131452.jpg>
 




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复