beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [04/50] [abbrv] incubator-beam git commit: DataflowRunner: get PBegin from PInput
Date Tue, 13 Sep 2016 00:40:35 GMT
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 <dhalperi@users.noreply.github.com>
Authored: Sat Aug 27 09:42:08 2016 -0700
Committer: Dan Halperin <dhalperi@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")


Mime
View raw message