The reason why I reopen it is that:
I can not resume from incremental checkpoint manually when I stop the following program by force(maybe NOT supported officially?).
|My Other Effort||Content||Result|
|①||I hava subscribed to mailing list||David Anderson has answered this several days ago. But he did not tell me how I can fix it.
I guess he's very busy.
|②||stackoverflow account||my account is forbidden to ask questions.|
|③||alibaba Flink dingtalk group||no one can answer this question|
|④||I have read document carefully||I can NOT succeed in it|
|⑤||apologise for post it here||how can I make sure this question is a support instead of a bug or due to my own mistake?
no successful example in Google/Baidu,am I right?
|⑥||about less than 1000 people visit my failure record about this experiment.||in vain|
original posting content--------------------------------
I want to do an experiment of"incremental checkpoint"
|pom.xml||[ is in the attachment]|
some of the above error is:
Caused by: java.lang.IllegalStateException: Unexpected state handle type, expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle
The steps for incremental experiment are:
|①||mvn clean scala:compile compile package|
|②||nc -lk 9999|
|③||flink run -c wordcount_increstate datastream_api-1.0-SNAPSHOT.jar
Job has been submitted with JobID df6d62a43620f258155b8538ef0ddf1b
|④||input the following conents in nc -lk 9999
|⑤||flink run -s hdfs://Desktop:9000/tmp/flinkck/df6d62a43620f258155b8538ef0ddf1b/chk-22 -c StateWordCount datastream_api-1.0-SNAPSHOT.jar|
Then the above error happens.