[jira] [Created] (BEAM-11784) Java pipeline proto serialization does not ensure topological ordering of root transforms

["Kenneth Knowles (Jira)" <ji...@apache.org>]

Kenneth Knowles created BEAM-11784:
--------------------------------------

             Summary: Java pipeline proto serialization does not ensure topological ordering of root transforms
                 Key: BEAM-11784
                 URL: https://issues.apache.org/jira/browse/BEAM-11784
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-core
            Reporter: Kenneth Knowles
            Assignee: Kenneth Knowles


Seen these root orders when running {{ImpulseTest.testImpulse}}:

 - {{["Impulse", "PAssert$0", "FlatMapElements"]}}
 - {{["FlatMapElements", "PAssert$0", "Impulse"]}}

Pipeline is:

{code}
PCollection<Integer> result =
        p.apply(Impulse.create())
            .apply(
                FlatMapElements.into(TypeDescriptors.integers())
                    .via(impulse -> Arrays.asList(1, 2, 3)));
    PAssert.that(result).containsInAnyOrder(1, 2, 3);
{code}

The topological order is linear and is neither of the above.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)