Ankur Goenka created BEAM-5041: ---------------------------------- Summary: Java Fn SDK Harness skips unprocessed pCollections Key: BEAM-5041 URL: https://issues.apache.org/jira/browse/BEAM-5041 Project: Beam Issue Type: Bug Components: sdk-java-harness Reporter: Ankur Goenka Assignee: Ankur Goenka
Java Sdk Harness used pCollections to keep track of computed consumers [here| https://github.com/apache/beam/blob/ff95a82e461bd8319d9733be60e75992ba90cd7c/sdks/java/harness/src/main/java/org/apache/beam/fn/harness/control/ProcessBundleHandler.java#L158 ] . This is incorrect as consumers are based on pTransforms so pTransforms should be used to keep track of computed processors. 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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)