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

Java Fn SDK Harness skips unprocessed pCollections

Details

    • Bug
    • Status: Resolved
    • P2
    • Resolution: Fixed
    • None
    • 2.7.0
    • sdk-java-harness

    Description

      Java Sdk Harness used pCollections to keep track of computed consumers here. This is incorrect as consumers are based on pTransforms so pTransforms should be used to keep track of computed consumers.

      In case of Flatten, this creates an issue where pTransforms having same input as that to flatten are not executed. This causes 

      https://github.com/apache/beam/blob/ff95a82e461bd8319d9733be60e75992ba90cd7c/sdks/java/core/src/test/java/org/apache/beam/sdk/transforms/FlattenTest.java#L316 to fail.

      Attachments

        Issue Links

          Activity

            People

              angoenka Ankur Goenka
              angoenka Ankur Goenka
              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 - 2h 20m
                  2h 20m