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)
