[FLINK-19486] expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Invalid
• Affects Version/s: 1.11.1
• Component/s: Runtime / Checkpointing, Runtime / State Backends
• Labels: pull-request-available
• Assignee: Unassigned
• Reporter: appleyuchi
• Created: 01/Oct/20 13:48
• Updated: 07/Oct/20 14:45
• Resolved: 06/Oct/20 09:22

Description

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 Experience	StateBackEnd	result
Normal Checkpoint	FsStateBackend	succeed
Incremental Checkpoint	RocksDBStateBackend	failed

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

 Please help,thanks~

 

--------------------------------original posting content--------------------------------

I want to do an experiment of"incremental checkpoint"

information	content
pom.xml	[ is in the attachment]
code	https://paste.ubuntu.com/p/DpTyQKq6Vk/
error	https://paste.ubuntu.com/p/49HRYXFzR2/

 

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:

step	content
①	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 before error error error error
⑤	flink run -s hdfs://Desktop:9000/tmp/flinkck/df6d62a43620f258155b8538ef0ddf1b/chk-22 -c StateWordCount datastream_api-1.0-SNAPSHOT.jar

Then the above error happens.

Please help,Thanks~!

 

Issue Links

• links to: GitHub Pull Request #13545