Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-19486

expected: class org.apache.flink.runtime.state.KeyGroupsStateHandle, but found: class org.apache.flink.runtime.state.IncrementalRemoteKeyedStateHandle

    XMLWordPrintableJSON

    Details

      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~!

       

        Attachments

        1. pom.xml
          3 kB
          appleyuchi

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                appleyuchi appleyuchi
              • Votes:
                0 Vote for this issue
                Watchers:
                4 Start watching this issue

                Dates

                • Created:
                  Updated:
                  Resolved: