[
https://issues.apache.org/jira/browse/FLINK-19486?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
appleyuchi updated FLINK-19486:
-------------------------------
Description:
*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
haved 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 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~!
was:
*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
haved 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~*
*The keypoint is:*
*①Of course I know checkpoint is for automatically resuming,it's basics.*
*②I want to stop the program by force(simulate Product Environment)with*
{color:#de350b} *incremental* {color}*{color:#de350b}checkpoint{color} and then
{color:#de350b}resume from{color}* {color:#de350b} *incremental* *checkpoint
manually*{color}
------------ ------------ ------------ --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 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~!
> 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
> Affects Versions: 1.11.1
> Reporter: appleyuchi
> Priority: Minor
> 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
> haved 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 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)
