You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/09/13 00:40:35 UTC
[04/50] [abbrv] incubator-beam git commit: DataflowRunner: get PBegin
from PInput
DataflowRunner: get PBegin from PInput
Fixes an invalid cast that breaks some PCollectionList-related tests.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/8454d5ca
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/8454d5ca
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/8454d5ca
Branch: refs/heads/gearpump-runner
Commit: 8454d5ca18c265ab1c5f54f2222c13d9ff17e4ef
Parents: 1c1115e
Author: Daniel Halperin <dh...@users.noreply.github.com>
Authored: Sat Aug 27 09:42:08 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon Sep 12 17:40:10 2016 -0700
----------------------------------------------------------------------
.../main/java/org/apache/beam/runners/dataflow/DataflowRunner.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/8454d5ca/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
index 0ce4b58..e5b6614 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowRunner.java
@@ -400,7 +400,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob> {
return windowed;
} else if (Flatten.FlattenPCollectionList.class.equals(transform.getClass())
&& ((PCollectionList<?>) input).size() == 0) {
- return (OutputT) Pipeline.applyTransform((PBegin) input, Create.of());
+ return (OutputT) Pipeline.applyTransform(input.getPipeline().begin(), Create.of());
} else if (overrides.containsKey(transform.getClass())) {
// It is the responsibility of whoever constructs overrides to ensure this is type safe.
@SuppressWarnings("unchecked")