[BEAM-4069] Empty pipeline options can be gracefully serialized/deserialized

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: Not applicable
• Component/s: runner-core
• Assignee: Ben Sidhom
• Reporter: Ben Sidhom
• Created: 13/Apr/18 17:45
• Updated: 24/Jul/20 20:20
• Resolved: 18/Apr/18 18:12

Description

PipelineOptionsTranslation.fromProto currently crashes with a NullPointerException when passed an empty options Struct. This is due to ProxyInvocationHandler.Deserializer expecting a non-empty enclosing Struct.

Empty pipeline options may be passed by SDKs interacting with a job server, so this case needs to be handled. Note that testing a round-trip of an effectively-empty Java PipelineOptions object is not sufficient to catch this because "empty" Java options still contain default fields not defined in other SDKs.

Issue Links

• is depended upon by: BEAM-2889 Flink runs portable pipelines
• links to: GitHub Pull Request #5126