Abacn commented on code in PR #24129:
URL: https://github.com/apache/beam/pull/24129#discussion_r1020670888
##########
.test-infra/dataproc/flink_cluster.sh:
##########
@@ -81,7 +81,7 @@ function get_leader() {
application_ids[$i]=`echo $line | sed "s/ .*//"`
application_masters[$i]=`echo $line | sed
"s/.*$CLUSTER_NAME/$CLUSTER_NAME/" | sed "s/ .*//"`
i=$((i+1))
- done <<< $(gcloud compute ssh --zone=$GCLOUD_ZONE --quiet yarn@$MASTER_NAME
--command="yarn application -list" | grep "$CLUSTER_NAME")
+ done <<< $(gcloud compute ssh --zone=$GCLOUD_ZONE --quiet yarn@$MASTER_NAME
--command="yarn application -list" | grep "Apache Flink")
Review Comment:
The line contains $CLUSTER_NAME if part of the domain contains it. Not
always be the case. domain can be an IP address.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
