diff --git a/examples/pom.xml b/examples/pom.xml index 22183670c2d4..c15f73f688ca 100644 --- a/examples/pom.xml +++ b/examples/pom.xml @@ -22,7 +22,7 @@ com.google.cloud.dataflow google-cloud-dataflow-java-sdk-parent - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT com.google.cloud.dataflow diff --git a/maven-archetypes/examples/pom.xml b/maven-archetypes/examples/pom.xml index 6cb1852562a5..4e999083b0b9 100644 --- a/maven-archetypes/examples/pom.xml +++ b/maven-archetypes/examples/pom.xml @@ -22,7 +22,7 @@ com.google.cloud.dataflow google-cloud-dataflow-java-sdk-parent - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT ../../pom.xml diff --git a/maven-archetypes/starter/pom.xml b/maven-archetypes/starter/pom.xml index b5b32514dcb2..0aa71c49f928 100644 --- a/maven-archetypes/starter/pom.xml +++ b/maven-archetypes/starter/pom.xml @@ -22,7 +22,7 @@ com.google.cloud.dataflow google-cloud-dataflow-java-sdk-parent - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT ../../pom.xml diff --git a/pom.xml b/pom.xml index 7e5e078339e7..6fb0b32a573e 100644 --- a/pom.xml +++ b/pom.xml @@ -35,7 +35,7 @@ http://cloud.google.com/dataflow 2013 - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT diff --git a/runners/flink/pom.xml b/runners/flink/pom.xml index b1929d217068..c8c5d848fdd7 100644 --- a/runners/flink/pom.xml +++ b/runners/flink/pom.xml @@ -25,7 +25,7 @@ org.apache.beam runners - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT flink-runner @@ -48,7 +48,7 @@ UTF-8 UTF-8 1.0.0 - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT 2.10 org.apache.beam.runners.flink.examples.WordCount diff --git a/runners/pom.xml b/runners/pom.xml index 757e2081d1cc..980900bf7a8b 100644 --- a/runners/pom.xml +++ b/runners/pom.xml @@ -25,12 +25,12 @@ com.google.cloud.dataflow google-cloud-dataflow-java-sdk-parent - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT org.apache.beam runners - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT pom diff --git a/sdk/pom.xml b/sdk/pom.xml index f782b7853247..d7e10a53a801 100644 --- a/sdk/pom.xml +++ b/sdk/pom.xml @@ -22,7 +22,7 @@ com.google.cloud.dataflow google-cloud-dataflow-java-sdk-parent - 1.5.0-SNAPSHOT + 1.6.0-SNAPSHOT com.google.cloud.dataflow diff --git a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java index c90b90423587..29f9b85cc529 100644 --- a/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java +++ b/sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java @@ -211,9 +211,9 @@ public class DataflowPipelineRunner extends PipelineRunner // 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:github-20160225-00"; + = "dataflow.gcr.io/v1beta3/java-batch:1.5.0"; public static final String STREAMING_WORKER_HARNESS_CONTAINER_IMAGE - = "dataflow.gcr.io/v1beta3/java-streaming:github-20160225-00"; + = "dataflow.gcr.io/v1beta3/java-streaming:1.5.0"; // The limit of CreateJob request size. private static final int CREATE_JOB_REQUEST_LIMIT_BYTES = 10 * 1024 * 1024;