This is an automated email from the ASF dual-hosted git repository.
mwalenia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 4b08e77 [BEAM-9226] Set max age of 3h for Dataproc Flink clusters
new b2a24c5 Merge pull request #10725 from
mwalenia/BEAM-9226-flink-clustetr-max-age
4b08e77 is described below
commit 4b08e7728744bc1ef2106f0766a6b1ccfaa7227b
Author: Michal Walenia <[email protected]>
AuthorDate: Thu Jan 30 10:05:48 2020 +0100
[BEAM-9226] Set max age of 3h for Dataproc Flink clusters
---
.test-infra/dataproc/flink_cluster.sh | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/.test-infra/dataproc/flink_cluster.sh
b/.test-infra/dataproc/flink_cluster.sh
index ad88578..89d61f1 100755
--- a/.test-infra/dataproc/flink_cluster.sh
+++ b/.test-infra/dataproc/flink_cluster.sh
@@ -134,7 +134,7 @@ function create_cluster() {
# Docker init action restarts yarn so we need to start yarn session after
this restart happens.
# This is why flink init action is invoked last.
- gcloud dataproc clusters create $CLUSTER_NAME --region=global
--num-workers=$num_dataproc_workers --initialization-actions
$DOCKER_INIT,$BEAM_INIT,$FLINK_INIT --metadata "${metadata}",
--image-version=$image_version --zone=$GCLOUD_ZONE --quiet
+ gcloud dataproc clusters create $CLUSTER_NAME --region=global
--num-workers=$num_dataproc_workers --initialization-actions
$DOCKER_INIT,$BEAM_INIT,$FLINK_INIT --metadata "${metadata}",
--image-version=$image_version --zone=$GCLOUD_ZONE --max-age=3h --quiet
}
# Runs init actions for Docker, Portability framework (Beam) and Flink cluster
