Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-1273

Error with FlinkPipelineOptions serialization after setStateBackend

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 0.5.0
    • runner-flink
    • None

    Description

      Trying setup FlinkPipelineOptions.setStateBackend cause error:

      Caused by: com.fasterxml.jackson.databind.JsonMappingException: Can not construct instance of org.apache.flink.runtime.state.AbstractStateBackend: abstract types either need to be mapped to concrete types, have custom deserializer, or contain additional type information.
      

      Exception was thrown in SerializedPipelineOptions.

      Main problem then AbstractStateBackend and their implementation can't be mapped in JSON schema for serialization.

      Error starting after:
      BEAM-617[flink] introduce option to set state backend

      Attachments

        Issue Links

          Activity

            People

              humanoid Alexey Diomin
              humanoid Alexey Diomin
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: