[
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||Content||result||
|Normal Checkpoint|succeed|
|Incremental Checkpoint|failed|
*①I {color:#de350b}hava subscribed to mailing list{color} and 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.*
*②My {color:#de350b}stackoverflow account{color} is forbidden to ask questions.*
*③No one in alibaba {color:#de350b}Flink dingtalk group{color} can answer this
question.*
*④I have read
[document](https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html)
carefully,but I can NOT succeed in it.*
*⑤{color:#de350b}apologise for post it here{color},but 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?*
*⑥{color:#de350b}about less than 1000 people visit my [failure record
|[https://yuchi.blog.csdn.net/article/details/108896441]]{color}about this
experiment.*
*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~!
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?).*
*①I {color:#de350b}hava subscribed to mailing list{color} and 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.*
*②My {color:#de350b}stackoverflow account{color} is forbidden to ask questions.*
*③No one in alibaba {color:#de350b}Flink dingtalk group{color} can answer this
question.*
*④I have read
[document](https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html)
carefully,but I can NOT succeed in it.*
*⑤{color:#de350b}apologise for post it here{color},but 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?*
*⑥{color:#de350b}about less than 1000 people visit my [failure record
|[https://yuchi.blog.csdn.net/article/details/108896441]]{color}about this
experiment.*
*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||Content||result||
> |Normal Checkpoint|succeed|
> |Incremental Checkpoint|failed|
> *①I {color:#de350b}hava subscribed to mailing list{color} and 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.*
> *②My {color:#de350b}stackoverflow account{color} is forbidden to ask
> questions.*
> *③No one in alibaba {color:#de350b}Flink dingtalk group{color} can answer
> this question.*
> *④I have read
> [document](https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html)
> carefully,but I can NOT succeed in it.*
> *⑤{color:#de350b}apologise for post it here{color},but 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?*
> *⑥{color:#de350b}about less than 1000 people visit my [failure record
> |[https://yuchi.blog.csdn.net/article/details/108896441]]{color}about this
> experiment.*
> *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~!
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
