Kyle Weaver created BEAM-8037:
---------------------------------
Summary: Python FlinkRunner does not override reads
Key: BEAM-8037
URL: https://issues.apache.org/jira/browse/BEAM-8037
Project: Beam
Issue Type: Bug
Components: runner-flink
Reporter: Kyle Weaver
Assignee: Kyle Weaver
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"
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
