Re: 使用BroadcastStream后checkpoint失效

hi    
checkpoint目前只能用在流数据上,你读取的mongo数据是一个有界的数据源,所以是不支持做checkpoint就会导致整个任务的checkpoint失败,你可以把读取mongo做一个定时读取,这样应该就可以完成checkpoint.




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

回复