[BEAM-3027] Output type of SourceID-stripper is not correctly set

• Type: Bug
• Status: Resolved
• Priority: P0
• Resolution: Fixed
• Fix Version/s: 2.2.0
• Component/s: runner-flink
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 06/Oct/17 12:54
• Updated: 24/Jul/20 20:19
• Resolved: 09/Oct/17 12:59

Description

This code: https://github.com/apache/beam/blob/be9fb29901cf4a1ae7b4a9d8e9f25f4ea78359fd/runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkStreamingTransformTranslators.java#L193

Does not set the output type of the flatMap to outputTypeInfo, which is the correct TypeInfo that uses the Beam coder. This means that Flink will use Kryo as a fallback, which can be problematic in cases.

Issue Links

• links to: GitHub Pull Request #3953