Luke Cwik created BEAM-10914:
--------------------------------
Summary: Splittable DoFn and Dataflow, "conflicting bucketing
functions"
Key: BEAM-10914
URL: https://issues.apache.org/jira/browse/BEAM-10914
Project: Beam
Issue Type: Bug
Components: runner-dataflow
Reporter: Luke Cwik
When creating a pipeline with an SDF like:
FileIO.match -> readMatches -> drive the upstream side input
OR
[unbounded watcher, sdf] -> [ParDo with side input from File.IO] -> [bounded
sdf] -> [ParDo]
Workflow failed. Causes: Step s22 has conflicting bucketing functions
Attached is a repro supplied by the user.
Source for reported issue:
https://lists.apache.org/thread.html/r03c77ea03d7ff2678052bde412da19c4e13050652fd34d3e03a9e30f%40%3Cuser.beam.apache.org%3E
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
