beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [1/2] incubator-beam git commit: Update DataflowPipelineRunner worker container version
Date Thu, 16 Jun 2016 02:23:47 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 021fa1e5f -> 414bb4bc3


Update DataflowPipelineRunner worker container version


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

Branch: refs/heads/master
Commit: f117f7121eeae0c55da7049757bc4dfab39d01d6
Parents: 021fa1e
Author: Scott Wegner <swegner@google.com>
Authored: Tue Jun 14 09:00:49 2016 -0700
Committer: Scott Wegner <swegner@google.com>
Committed: Wed Jun 15 16:24:07 2016 -0700

----------------------------------------------------------------------
 .../org/apache/beam/runners/dataflow/DataflowPipelineRunner.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f117f712/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRunner.java
----------------------------------------------------------------------
diff --git a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRunner.java
b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRunner.java
index 2d34f23..1eb39ad 100644
--- a/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRunner.java
+++ b/runners/google-cloud-dataflow-java/src/main/java/org/apache/beam/runners/dataflow/DataflowPipelineRunner.java
@@ -220,9 +220,9 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
   // Default Docker container images that execute Dataflow worker harness, residing in Google
   // Container Registry, separately for Batch and Streaming.
   public static final String BATCH_WORKER_HARNESS_CONTAINER_IMAGE
-      = "dataflow.gcr.io/v1beta3/beam-java-batch:beam-master-20160427";
+      = "dataflow.gcr.io/v1beta3/beam-java-batch:beam-master-20160613";
   public static final String STREAMING_WORKER_HARNESS_CONTAINER_IMAGE
-      = "dataflow.gcr.io/v1beta3/beam-java-streaming:beam-master-20160427";
+      = "dataflow.gcr.io/v1beta3/beam-java-streaming:beam-master-20160613";
 
   // The limit of CreateJob request size.
   private static final int CREATE_JOB_REQUEST_LIMIT_BYTES = 10 * 1024 * 1024;


Mime
View raw message