beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From amits...@apache.org
Subject [39/50] [abbrv] incubator-beam git commit: Dataflow goes GA! Update to version 1.0.0.
Date Thu, 10 Mar 2016 20:59:04 GMT
Dataflow goes GA! Update to version 1.0.0.


Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/27fd2904
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/27fd2904
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/27fd2904

Branch: refs/heads/master
Commit: 27fd2904240c58fcb492477e86fed307089d4cac
Parents: 922508c
Author: Tom White <tom@cloudera.com>
Authored: Thu Aug 13 16:58:32 2015 +0100
Committer: Tom White <tom@cloudera.com>
Committed: Thu Mar 10 11:15:16 2016 +0000

----------------------------------------------------------------------
 runners/spark/pom.xml                                            | 2 +-
 .../java/com/cloudera/dataflow/spark/SparkProcessContext.java    | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/27fd2904/runners/spark/pom.xml
----------------------------------------------------------------------
diff --git a/runners/spark/pom.xml b/runners/spark/pom.xml
index d055fea..fadb372 100644
--- a/runners/spark/pom.xml
+++ b/runners/spark/pom.xml
@@ -23,7 +23,7 @@ License.
         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
         <java.version>1.7</java.version>
         <spark.version>1.3.1</spark.version>
-        <google-cloud-dataflow-version>0.4.150727</google-cloud-dataflow-version>
+        <google-cloud-dataflow-version>1.0.0</google-cloud-dataflow-version>
     </properties>
 
     <build>

http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/27fd2904/runners/spark/src/main/java/com/cloudera/dataflow/spark/SparkProcessContext.java
----------------------------------------------------------------------
diff --git a/runners/spark/src/main/java/com/cloudera/dataflow/spark/SparkProcessContext.java
b/runners/spark/src/main/java/com/cloudera/dataflow/spark/SparkProcessContext.java
index 259f90c..7777f21 100644
--- a/runners/spark/src/main/java/com/cloudera/dataflow/spark/SparkProcessContext.java
+++ b/runners/spark/src/main/java/com/cloudera/dataflow/spark/SparkProcessContext.java
@@ -127,7 +127,7 @@ abstract class SparkProcessContext<I, O, V> extends DoFn<I, O>.ProcessContext
{
 
   @Override
   public PaneInfo pane() {
-    return PaneInfo.DEFAULT;
+    return PaneInfo.NO_FIRING;
   }
 
   @Override
@@ -159,7 +159,7 @@ abstract class SparkProcessContext<I, O, V> extends DoFn<I, O>.ProcessContext
{
 
       @Override
       public PaneInfo pane() {
-        return PaneInfo.DEFAULT;
+        return PaneInfo.NO_FIRING;
       }
 
       @Override


Mime
View raw message