Skip to content
This repository has been archived by the owner on Nov 11, 2022. It is now read-only.

Commit

Permalink
DataflowPipelineRunner: preparation for 1.8.1 release
Browse files Browse the repository at this point in the history
[]

-------------
Created by MOE: https://github.com/google/moe
MOE_MIGRATED_REVID=141532913
  • Loading branch information
dhalperi committed Dec 10, 2016
1 parent ab335e6 commit 10da971
Showing 1 changed file with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -216,14 +216,14 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
private DataflowPipelineRunnerHooks 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.
public static final String BATCH_WORKER_HARNESS_CONTAINER_IMAGE
= "dataflow.gcr.io/v1beta3/java-batch:1.8.0";
= "dataflow.gcr.io/v1beta3/java-batch:1.8.1";
public static final String STREAMING_WORKER_HARNESS_CONTAINER_IMAGE
= "dataflow.gcr.io/v1beta3/java-streaming:1.8.0";
= "dataflow.gcr.io/v1beta3/java-streaming:1.8.1";

// The limit of CreateJob request size.
private static final int CREATE_JOB_REQUEST_LIMIT_BYTES = 10 * 1024 * 1024;
Expand Down

0 comments on commit 10da971

Please sign in to comment.