[BEAM-8037] Python FlinkRunner does not override reads

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 2.16.0
• Component/s: runner-flink
• Labels: portability-flink
• Assignee: Kyle Weaver
• Reporter: Kyle Weaver
• Created: 22/Aug/19 17:42
• Updated: 24/Jul/20 20:01
• Resolved: 22/Aug/19 20:55

Description

When using the Python FlinkRunner [1],  my example pipeline (beginning with a Create transform) failed with exception:

java.lang.IllegalArgumentException: GreedyPipelineFuser requires all root nodes to be runner-implemented beam:transform:impulse:v1 or beam:transform:read:v1 primitives, but transform ref_AppliedPTransform_Create/Read_3 executes in environment Optional[urn: "beam:env:docker:v1"

Issue Links

• links to: GitHub Pull Request #9402