Uploaded image for project: 'Beam'
  1. Beam
  2. BEAM-11784

Java pipeline proto serialization does not ensure topological ordering of root transforms

Details

    Description

      Seen these root orders when running ImpulseTest.testImpulse:

      • ["Impulse", "PAssert$0", "FlatMapElements"]
      • ["FlatMapElements", "PAssert$0", "Impulse"]

      Pipeline is:

      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);
      

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

      Attachments

        Issue Links

          Activity

            People

              kenn Kenneth Knowles
              kenn Kenneth Knowles
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved:

                Time Tracking

                  Estimated:
                  Original Estimate - Not Specified
                  Not Specified
                  Remaining:
                  Remaining Estimate - 0h
                  0h
                  Logged:
                  Time Spent - 1h
                  1h

                  Slack

                    Issue deployment