Details
-
Bug
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
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"
Attachments
Issue Links
- links to