File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
sdk/src/main/java/com/google/cloud/dataflow/sdk/runners Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -222,9 +222,9 @@ public class DataflowPipelineRunner extends PipelineRunner<DataflowPipelineJob>
222
222
// Default Docker container images that execute Dataflow worker harness, residing in Google
223
223
// Container Registry, separately for Batch and Streaming.
224
224
public static final String BATCH_WORKER_HARNESS_CONTAINER_IMAGE
225
- = "dataflow.gcr.io/v1beta3/java-batch:1.8.1 " ;
225
+ = "dataflow.gcr.io/v1beta3/java-batch:1.9.0 " ;
226
226
public static final String STREAMING_WORKER_HARNESS_CONTAINER_IMAGE
227
- = "dataflow.gcr.io/v1beta3/java-streaming:1.8.1 " ;
227
+ = "dataflow.gcr.io/v1beta3/java-streaming:1.9.0 " ;
228
228
229
229
// The limit of CreateJob request size.
230
230
private static final int CREATE_JOB_REQUEST_LIMIT_BYTES = 10 * 1024 * 1024 ;
You can’t perform that action at this time.
0 commit comments