[
https://issues.apache.org/jira/browse/BEAM-8037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Kyle Weaver closed BEAM-8037.
-----------------------------
Fix Version/s: 2.16.0
Resolution: Fixed
> 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
> Priority: Major
> Labels: portability-flink
> Fix For: 2.16.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> 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)
