[jira] [Created] (BEAM-1273) Error with FlinkPipelineOptions serialization after setStateBackend

["Alexey Diomin (JIRA)" <ji...@apache.org>]

Alexey Diomin created BEAM-1273:
-----------------------------------

             Summary: Error with FlinkPipelineOptions serialization after setStateBackend
                 Key: BEAM-1273
                 URL: https://issues.apache.org/jira/browse/BEAM-1273
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Alexey Diomin
            Assignee: Aljoscha Krettek


Trying setup FlinkPipelineOptions.setStateBackend cause error:

{code}
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.
{code}

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



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)