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

Commit ab335e6

Browse files
authored
Merge pull request #459 from dhalperi/containers-180
Version management: use 1.8.0 worker container
2 parents fe13fb7 + 6c0fc49 commit ab335e6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

sdk/src/main/java/com/google/cloud/dataflow/sdk/runners/DataflowPipelineRunner.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -221,9 +221,9 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
221221
// Default Docker container images that execute Dataflow worker harness, residing in Google
222222
// Container Registry, separately for Batch and Streaming.
223223
public static final String BATCH_WORKER_HARNESS_CONTAINER_IMAGE
224-
= "dataflow.gcr.io/v1beta3/java-batch:1.7.0";
224+
= "dataflow.gcr.io/v1beta3/java-batch:1.8.0";
225225
public static final String STREAMING_WORKER_HARNESS_CONTAINER_IMAGE
226-
= "dataflow.gcr.io/v1beta3/java-streaming:1.7.0";
226+
= "dataflow.gcr.io/v1beta3/java-streaming:1.8.0";
227227

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

0 commit comments

Comments
 (0)