[BEAM-6195] Make ProcessRemoteBundleOperation map PCollectionId into correct...
[BEAM-6195] Make ProcessRemoteBundleOperation map PCollectionId into correct OutputReceiver and throws Exception when there is more than one input PCollection. (#7223)
显示
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BatchDataflowWorker.java 1 个添加, 1 个删除...che/beam/runners/dataflow/worker/BatchDataflowWorker.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java 9 个添加, 8 个删除...runners/dataflow/worker/BeamFnMapTaskExecutorFactory.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java 1 个添加, 1 个删除...ners/dataflow/worker/IntrinsicMapTaskExecutorFactory.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/StreamingDataflowWorker.java 1 个添加, 1 个删除...beam/runners/dataflow/worker/StreamingDataflowWorker.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/fn/control/ProcessRemoteBundleOperation.java 12 个添加, 8 个删除...aflow/worker/fn/control/ProcessRemoteBundleOperation.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CloneAmbiguousFlattensFunction.java 6 个添加, 3 个删除...dataflow/worker/graph/CloneAmbiguousFlattensFunction.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateExecutableStageNodeFunction.java 5 个添加, 1 个删除...aflow/worker/graph/CreateExecutableStageNodeFunction.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/CreateRegisterFnOperationFunction.java 4 个添加, 2 个删除...aflow/worker/graph/CreateRegisterFnOperationFunction.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodes.java 2 个添加, 1 个删除...er/graph/InsertFetchAndFilterStreamingSideInputNodes.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/LengthPrefixUnknownCoders.java 2 个添加, 2 个删除...ners/dataflow/worker/graph/LengthPrefixUnknownCoders.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/MapTaskToNetworkFunction.java 10 个添加, 1 个删除...nners/dataflow/worker/graph/MapTaskToNetworkFunction.java
- runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/graph/Nodes.java 14 个添加, 5 个删除.../org/apache/beam/runners/dataflow/worker/graph/Nodes.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/IntrinsicMapTaskExecutorFactoryTest.java 12 个添加, 6 个删除.../dataflow/worker/IntrinsicMapTaskExecutorFactoryTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/CloneAmbiguousFlattensFunctionTest.java 1 个添加, 1 个删除...flow/worker/graph/CloneAmbiguousFlattensFunctionTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/CreateRegisterFnOperationFunctionTest.java 1 个添加, 1 个删除...w/worker/graph/CreateRegisterFnOperationFunctionTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/DeduceFlattenLocationsFunctionTest.java 1 个添加, 1 个删除...flow/worker/graph/DeduceFlattenLocationsFunctionTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/DeduceNodeLocationsFunctionTest.java 2 个添加, 2 个删除...ataflow/worker/graph/DeduceNodeLocationsFunctionTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/InsertFetchAndFilterStreamingSideInputNodesTest.java 4 个添加, 3 个删除...raph/InsertFetchAndFilterStreamingSideInputNodesTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/LengthPrefixUnknownCodersTest.java 1 个添加, 1 个删除.../dataflow/worker/graph/LengthPrefixUnknownCodersTest.java
- runners/google-cloud-dataflow-java/worker/src/test/java/org/apache/beam/runners/dataflow/worker/graph/MapTaskToNetworkFunctionTest.java 17 个添加, 8 个删除...s/dataflow/worker/graph/MapTaskToNetworkFunctionTest.java
加载中
想要评论请 注册 或 登录