See 
<https://ci-beam.apache.org/job/beam_LoadTests_Python_Combine_Flink_Streaming/1116/display/redirect>

Changes:


------------------------------------------
Started by timer
Running as SYSTEM
[EnvInject] - Loading node environment variables.
Building remotely on apache-beam-jenkins-2 (beam) in workspace 
<https://ci-beam.apache.org/job/beam_LoadTests_Python_Combine_Flink_Streaming/ws/>
The recommended git tool is: NONE
No credentials specified
Wiping out workspace first.
Cloning the remote Git repository
Using shallow clone with depth 1
Avoid fetching tags
Cloning repository https://github.com/apache/beam.git
 > git init 
 > <https://ci-beam.apache.org/job/beam_LoadTests_Python_Combine_Flink_Streaming/ws/src>
 >  # timeout=10
Fetching upstream changes from https://github.com/apache/beam.git
 > git --version # timeout=10
 > git --version # 'git version 2.25.1'
 > git fetch --no-tags --force --progress --depth=1 -- 
 > https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* # 
 > timeout=10
 > git config remote.origin.url https://github.com/apache/beam.git # timeout=10
 > git config --add remote.origin.fetch +refs/heads/*:refs/remotes/origin/* # 
 > timeout=10
 > git config remote.origin.url https://github.com/apache/beam.git # timeout=10
Using shallow fetch with depth 1
Fetching upstream changes from https://github.com/apache/beam.git
 > git fetch --no-tags --force --progress --depth=1 -- 
 > https://github.com/apache/beam.git +refs/heads/*:refs/remotes/origin/* 
 > +refs/pull/${ghprbPullId}/*:refs/remotes/origin/pr/${ghprbPullId}/* # 
 > timeout=10
 > git rev-parse origin/master^{commit} # timeout=10
Checking out Revision b9398e0e3e9e9b448fb082cb7ed5893af2d202f0 (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f b9398e0e3e9e9b448fb082cb7ed5893af2d202f0 # timeout=10
Commit message: "Add Java JMH workflow (#28860)"
 > git rev-list --no-walk 31e1c7a8aef905a54c5382930e43e2d36d2d5773 # timeout=10
First time build. Skipping changelog.
No emails were triggered.
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
SETUPTOOLS_USE_DISTUTILS=stdlib
SPARK_LOCAL_IP=127.0.0.1

[EnvInject] - Variables injected successfully.
[EnvInject] - Injecting environment variables from a build step.
[EnvInject] - Injecting as environment variables the properties content 
CLUSTER_NAME=beam-loadtests-python-combine-flink-streaming-1116
FLINK_NUM_WORKERS=16
DETACHED_MODE=true
JOB_SERVER_IMAGE=gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest
GCS_BUCKET=gs://beam-flink-cluster
HARNESS_IMAGES_TO_PULL=gcr.io/apache-beam-testing/beam-sdk/beam_python3.8_sdk:latest
HADOOP_DOWNLOAD_URL=https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
GCLOUD_ZONE=us-central1-a
FLINK_TASKMANAGER_SLOTS=1
FLINK_DOWNLOAD_URL=https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz
ARTIFACTS_DIR=gs://beam-flink-cluster/beam-loadtests-python-combine-flink-streaming-1116

[EnvInject] - Variables injected successfully.
[beam_LoadTests_Python_Combine_Flink_Streaming] $ /bin/bash -xe 
/tmp/jenkins1106336174228721967.sh
+ echo Setting up flink cluster
Setting up flink cluster
[beam_LoadTests_Python_Combine_Flink_Streaming] $ /bin/bash -xe 
/tmp/jenkins4250483223454951303.sh
+ cd 
<https://ci-beam.apache.org/job/beam_LoadTests_Python_Combine_Flink_Streaming/ws/src/.test-infra/dataproc>
+ ./flink_cluster.sh create
+ GCLOUD_ZONE=us-central1-a
+ DATAPROC_VERSION=2.1-debian
++ echo us-central1-a
++ sed -E 's/(-[a-z])?$//'
+ GCLOUD_REGION=us-central1
+ MASTER_NAME=beam-loadtests-python-combine-flink-streaming-1116-m
+ INIT_ACTIONS_FOLDER_NAME=init-actions
+ FLINK_INIT=gs://beam-flink-cluster/init-actions/flink.sh
+ BEAM_INIT=gs://beam-flink-cluster/init-actions/beam.sh
+ DOCKER_INIT=gs://beam-flink-cluster/init-actions/docker.sh
+ FLINK_LOCAL_PORT=8081
+ FLINK_TASKMANAGER_SLOTS=1
+ YARN_APPLICATION_MASTER=
+ create
+ upload_init_actions
+ echo 'Uploading initialization actions to GCS bucket: gs://beam-flink-cluster'
Uploading initialization actions to GCS bucket: gs://beam-flink-cluster
+ gsutil cp -r init-actions/beam.sh init-actions/docker.sh 
init-actions/flink.sh gs://beam-flink-cluster/init-actions
Copying file://init-actions/beam.sh [Content-Type=text/x-sh]...
/ [0 files][    0.0 B/  2.3 KiB]                                                
/ [1 files][  2.3 KiB/  2.3 KiB]                                                
Copying file://init-actions/docker.sh [Content-Type=text/x-sh]...
/ [1 files][  2.3 KiB/  6.0 KiB]                                                
/ [2 files][  6.0 KiB/  6.0 KiB]                                                
Copying file://init-actions/flink.sh [Content-Type=text/x-sh]...
/ [2 files][  6.0 KiB/ 13.5 KiB]                                                
/ [3 files][ 13.5 KiB/ 13.5 KiB]                                                
-
Operation completed over 3 objects/13.5 KiB.                                    
 
+ create_cluster
+ local 
metadata=flink-snapshot-url=https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz,
+ metadata+=flink-start-yarn-session=true,
+ metadata+=flink-taskmanager-slots=1,
+ 
metadata+=hadoop-jar-url=https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar
+ [[ -n gcr.io/apache-beam-testing/beam-sdk/beam_python3.8_sdk:latest ]]
+ 
metadata+=,beam-sdk-harness-images-to-pull=gcr.io/apache-beam-testing/beam-sdk/beam_python3.8_sdk:latest
+ [[ -n 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest ]]
+ 
metadata+=,beam-job-server-image=gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest
+ local image_version=2.1-debian
+ echo 'Starting dataproc cluster. Dataproc version: 2.1-debian'
Starting dataproc cluster. Dataproc version: 2.1-debian
+ gcloud dataproc clusters create 
beam-loadtests-python-combine-flink-streaming-1116 --region=us-central1 
--num-****s=16 --master-machine-type=n1-standard-2 
--****-machine-type=n1-standard-2 --metadata 
flink-snapshot-url=https://archive.apache.org/dist/flink/flink-1.15.0/flink-1.15.0-bin-scala_2.12.tgz,flink-start-yarn-session=true,flink-taskmanager-slots=1,hadoop-jar-url=https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.8.3-10.0/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar,beam-sdk-harness-images-to-pull=gcr.io/apache-beam-testing/beam-sdk/beam_python3.8_sdk:latest,beam-job-server-image=gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest,
 --image-version=2.1-debian --zone=us-central1-a 
--optional-components=FLINK,DOCKER --quiet
Waiting on operation 
[projects/apache-beam-testing/regions/us-central1/operations/0ae2aabc-62e1-349b-9abe-786c5fbb432a].
Waiting for cluster creation operation...
WARNING: Consider using Auto Zone rather than selecting a zone manually. See 
https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/auto-zone
WARNING: Permissions are missing for the default service account 
'[email protected]', missing permissions: 
[storage.objects.get, storage.objects.update] on the staging_bucket 
'projects/_/buckets/dataproc-staging-us-central1-844138762903-fb7i4jhf'. This 
usually happens when a custom resource (ex: custom staging bucket) or a 
user-managed VM Service account has been provided and the default/user-managed 
service account hasn't been granted enough permissions on the resource. See 
https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/service-accounts#VM_service_account.
WARNING: Permissions are missing for the default service account 
'[email protected]', missing permissions: 
[storage.objects.get, storage.objects.update] on the temp_bucket 
'projects/_/buckets/dataproc-temp-us-central1-844138762903-khnec1vl'. This 
usually happens when a custom resource (ex: custom staging bucket) or a 
user-managed VM Service account has been provided and the default/user-managed 
service account hasn't been granted enough permissions on the resource. See 
https://cloud.google.com/dataproc/docs/concepts/configuring-clusters/service-accounts#VM_service_account.
WARNING: The firewall rules for specified network or subnetwork would allow 
ingress traffic from 0.0.0.0/0, which could be a security risk.
......................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................done.
Created 
[https://dataproc.googleapis.com/v1/projects/apache-beam-testing/regions/us-central1/clusters/beam-loadtests-python-combine-flink-streaming-1116]
 Cluster placed in zone [us-central1-a].
+ get_leader
+ local i=0
+ local application_ids
+ local application_masters
+ echo 'Yarn Applications'
Yarn Applications
++ gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-python-combine-flink-streaming-1116-m '--command=yarn 
application -list'
++ grep 'Apache Flink'
Writing 3 keys to /home/jenkins/.ssh/google_compute_known_hosts
2023-10-06 17:57:27,113 INFO client.DefaultNoHARMFailoverProxyProvider: 
Connecting to ResourceManager at 
beam-loadtests-python-combine-flink-streaming-1116-m.c.apache-beam-testing.internal./10.128.0.224:8032
2023-10-06 17:57:27,440 INFO client.AHSProxy: Connecting to Application History 
server at 
beam-loadtests-python-combine-flink-streaming-1116-m.c.apache-beam-testing.internal./10.128.0.224:10200
+ read line
+ echo application_1696614921332_0001 flink-dataproc Apache Flink root default 
RUNNING UNDEFINED 100% http://10.128.1.18:46507
application_1696614921332_0001 flink-dataproc Apache Flink root default RUNNING 
UNDEFINED 100% http://10.128.1.18:46507
++ echo application_1696614921332_0001 flink-dataproc Apache Flink root default 
RUNNING UNDEFINED 100% http://10.128.1.18:46507
++ sed 's/ .*//'
+ application_ids[$i]=application_1696614921332_0001
++ echo application_1696614921332_0001 flink-dataproc Apache Flink root default 
RUNNING UNDEFINED 100% http://10.128.1.18:46507
++ sed -E 's#.*(https?://)##'
++ sed 's/ .*//'
+ application_masters[$i]=10.128.1.18:46507
+ i=1
+ read line
+ '[' 1 '!=' 1 ']'
+ YARN_APPLICATION_MASTER=10.128.1.18:46507
+ echo 'Using Yarn Application master: 10.128.1.18:46507'
Using Yarn Application master: 10.128.1.18:46507
+ [[ -n 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest ]]
+ start_job_server
+ gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-python-combine-flink-streaming-1116-m '--command=sudo 
--user yarn docker run --detach --publish 8099:8099 --publish 8098:8098 
--publish 8097:8097 --volume ~/.config/gcloud:/root/.config/gcloud 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.15_job_server:latest 
--flink-master=10.128.1.18:46507 
--artifacts-dir=gs://beam-flink-cluster/beam-loadtests-python-combine-flink-streaming-1116'
ERROR: (gcloud.compute.ssh) Could not fetch resource:
 - The service is currently unavailable.

Build step 'Execute shell' marked build as failure

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to