[
https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17208569#comment-17208569
]
appleyuchi commented on FLINK-19486:
------------------------------------
Thanks for your replies.
There are two possibilities that I'm wrong:
||the step I'm Wrong||what I have done||
|Wrong in the code|set RocksDBStateBackend in code as the official document
said|
|wrong in command|the command I use is almost the same as Resuming from
savepoint|
> expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but
> found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle
> ------------------------------------------------------------------------------------------------------------------------------------------------------
>
> Key: FLINK-19486
> URL: https://issues.apache.org/jira/browse/FLINK-19486
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing, Runtime / State Backends
> Affects Versions: 1.11.1
> Reporter: appleyuchi
> Priority: Major
> Fix For: 1.11.1
>
> Attachments: pom.xml
>
>
> *The reason why I reopen it is that:*
>
> *I can {color:#de350b}not{color} {color:#de350b}resume from incremental
> checkpoint manually{color} 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 {color:#de350b}hava subscribed to mailing list{color}*|*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.*
> |②|{color:#de350b}stackoverflow account{color}|it is forbidden to ask
> questions.
> |③|alibaba {color:#de350b}Flink dingtalk group{color}|no one can answer this
> question
> |④|I have read
> [document|https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html]
> 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|https://yuchi.blog.csdn.net/article/details/108896441] 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~!
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
