[BEAM-1273] Error with FlinkPipelineOptions serialization after setStateBackend

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.5.0
• Component/s: runner-flink
• Assignee: Alexey Diomin
• Reporter: Alexey Diomin
• Created: 16/Jan/17 06:55
• Updated: 24/Jul/20 20:15
• Resolved: 23/Jan/17 16:40

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

Issue Links

• links to: GitHub Pull Request #1779