beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Alexey Diomin (JIRA)" <>
Subject [jira] [Created] (BEAM-1273) Error with FlinkPipelineOptions serialization after setStateBackend
Date Mon, 16 Jan 2017 06:55:26 GMT
Alexey Diomin created BEAM-1273:

             Summary: Error with FlinkPipelineOptions serialization after setStateBackend
                 Key: BEAM-1273
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Alexey Diomin
            Assignee: Aljoscha Krettek

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

This message was sent by Atlassian JIRA

View raw message