finish为啥会导致ckpt不触发。 restart <[email protected]> 于2020年11月3日周二 上午10:11写道：
> 问题：job在接入广播流后，checkpint失效。 > > 描述：广播流的数据来源两个地方，一个是从mongo,一个是从kafka，数据进行union，同时指定Watermark，返回Watermark.MAX_WATERMARK（用于与主数据源connect后，窗口聚合水印更新），job部署后，来源mongo的数据源状态会变为FINISHED。网上有查过，说subtask > 状态finished会导致checkpoint不触发，那如何既能满足数据源自定义(更像是DataSet)，同时保证checkpoint正常触发呢 > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/
