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: DataflowRunner: bump environment major version
Date Fri, 09 Dec 2016 09:43:27 GMT
Repository: incubator-beam
Updated Branches:
  refs/heads/master 9bab78b55 -> 63d197cd0


DataflowRunner: bump environment major 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/9bcba398
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9bcba398
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9bcba398

Branch: refs/heads/master
Commit: 9bcba398c7516437c00517e03d75e27544b01166
Parents: 9bab78b
Author: Dan Halperin <dhalperi@google.com>
Authored: Fri Dec 9 15:15:19 2016 +0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Fri Dec 9 15:15:19 2016 +0800

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


http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/9bcba398/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 00c94d0..22f6f5a 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
@@ -205,7 +205,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob>
{
   private DataflowRunnerHooks hooks;
 
   // Environment version information.
-  private static final String ENVIRONMENT_MAJOR_VERSION = "5";
+  private static final String ENVIRONMENT_MAJOR_VERSION = "6";
 
   // Default Docker container images that execute Dataflow worker harness, residing in Google
   // Container Registry, separately for Batch and Streaming.
@@ -218,7 +218,7 @@ public class DataflowRunner extends PipelineRunner<DataflowPipelineJob>
{
   private static final int CREATE_JOB_REQUEST_LIMIT_BYTES = 10 * 1024 * 1024;
 
   @VisibleForTesting
-  static final int GCS_UPLOAD_BUFFER_SIZE_BYTES_DEFAULT = 1 * 1024 * 1024;
+  static final int GCS_UPLOAD_BUFFER_SIZE_BYTES_DEFAULT = 1024 * 1024;
 
   private final Set<PCollection<?>> pcollectionsRequiringIndexedFormat;
 


Mime
View raw message