You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by am...@apache.org on 2016/03/10 21:59:04 UTC
[39/50] [abbrv] incubator-beam git commit: Dataflow goes GA! Update
to version 1.0.0.
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 <to...@cloudera.com>
Authored: Thu Aug 13 16:58:32 2015 +0100
Committer: Tom White <to...@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