Re: 回复: need help about "incremental checkpoint",Thanks

2020-10-02 Thread Yun Tang
ink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/AbstractFsCheckpointStorage.java#L60 Best Yun Tang From: 大森林 Sent: Saturday, October 3, 2020 9:30 To: David Anderson Cc: user Subject: 回复: need help about "incremental checkpoint",T

Re: 回复: need help about "incremental checkpoint",Thanks

2020-10-06 Thread Aljoscha Krettek
I'm forwarding my comment from the Jira Issue [1]: In https://github.com/appleyuchi/wrongcheckpoint/blob/master/src/main/scala/wordcount_increstate.scala you set the RocksDBStateBackend, in https://github.com/appleyuchi/wrongcheckpoint/blob/master/src/main/scala/StateWordCount.scala you set t