You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by mw...@apache.org on 2020/01/31 08:54:03 UTC
[beam] branch revert-10725-BEAM-9226-flink-clustetr-max-age created
(now 9abc3d6)
This is an automated email from the ASF dual-hosted git repository.
mwalenia pushed a change to branch revert-10725-BEAM-9226-flink-clustetr-max-age
in repository https://gitbox.apache.org/repos/asf/beam.git.
at 9abc3d6 Revert "[BEAM-9226] Set max age of 3h for Dataproc Flink clusters"
This branch includes the following new commits:
new 9abc3d6 Revert "[BEAM-9226] Set max age of 3h for Dataproc Flink clusters"
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[beam] 01/01: Revert "[BEAM-9226] Set max age of 3h for Dataproc
Flink clusters"
Posted by mw...@apache.org.
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 <32...@users.noreply.github.com>
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