This is an automated email from the ASF dual-hosted git repository. mwalenia pushed a commit to branch revert-10725-BEAM-9226-flink-clustetr-max-age in repository https://gitbox.apache.org/repos/asf/beam.git
commit 9abc3d671f310989790121fa4538fa7e94d39fa5 Author: Michal Walenia <[email protected]> AuthorDate: Fri Jan 31 09:53:49 2020 +0100 Revert "[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 89d61f1..ad88578 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 --max-age=3h --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 --quiet } # Runs init actions for Docker, Portability framework (Beam) and Flink cluster
