See 
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/480/display/redirect>

Changes:


------------------------------------------
Started by timer
Running as SYSTEM
[EnvInject] - Loading node environment variables.
Building remotely on apache-beam-jenkins-15 (beam) in workspace 
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/>
The recommended git tool is: NONE
No credentials specified
Wiping out workspace first.
Cloning the remote Git repository
Cloning repository https://github.com/apache/beam.git
 > git init 
 > <https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/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 --tags --force --progress -- 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
Fetching upstream changes from https://github.com/apache/beam.git
 > git fetch --tags --force --progress -- 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 34e876d0bd6953927c89fb3f1ded5f453dded55c (origin/master)
 > git config core.sparsecheckout # timeout=10
 > git checkout -f 34e876d0bd6953927c89fb3f1ded5f453dded55c # timeout=10
Commit message: "Merge pull request #17177: [BEAM-14087] Mapped 
JOB_STATE_RESOURCE_CLEANING_UP to RESOURCE_CLEANING_UP in Pyth…"
 > git rev-list --no-walk 34e876d0bd6953927c89fb3f1ded5f453dded55c # timeout=10
No emails were triggered.
[EnvInject] - Executing scripts and injecting environment variables after the 
SCM step.
[EnvInject] - Injecting as environment variables the properties content 
SPARK_LOCAL_IP=127.0.0.1
SETUPTOOLS_USE_DISTUTILS=stdlib

[EnvInject] - Variables injected successfully.
[EnvInject] - Injecting environment variables from a build step.
[EnvInject] - Injecting as environment variables the properties content 
JOB_SERVER_IMAGE=gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest
CLUSTER_NAME=beam-loadtests-go-gbk-flink-batch-480
DETACHED_MODE=true
HARNESS_IMAGES_TO_PULL=gcr.io/apache-beam-testing/beam_portability/beam_go_sdk:latest
FLINK_NUM_WORKERS=5
FLINK_DOWNLOAD_URL=https://archive.apache.org/dist/flink/flink-1.12.3/flink-1.12.3-bin-scala_2.11.tgz
GCS_BUCKET=gs://beam-flink-cluster
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
FLINK_TASKMANAGER_SLOTS=1
ARTIFACTS_DIR=gs://beam-flink-cluster/beam-loadtests-go-gbk-flink-batch-480
GCLOUD_ZONE=us-central1-a

[EnvInject] - Variables injected successfully.
[beam_LoadTests_Go_GBK_Flink_Batch] $ /bin/bash -xe 
/tmp/jenkins5099649434759949457.sh
+ echo Setting up flink cluster
Setting up flink cluster
[beam_LoadTests_Go_GBK_Flink_Batch] $ /bin/bash -xe 
/tmp/jenkins4066515185541823774.sh
+ cd 
<https://ci-beam.apache.org/job/beam_LoadTests_Go_GBK_Flink_Batch/ws/src/.test-infra/dataproc>
+ ./flink_cluster.sh create
+ GCLOUD_ZONE=us-central1-a
+ DATAPROC_VERSION=2.0
+ GCLOUD_REGION=us-central1
+ MASTER_NAME=beam-loadtests-go-gbk-flink-batch-480-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.12.3/flink-1.12.3-bin-scala_2.11.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_portability/beam_go_sdk:latest ]]
+ 
metadata+=,beam-sdk-harness-images-to-pull=gcr.io/apache-beam-testing/beam_portability/beam_go_sdk:latest
+ [[ -n 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest ]]
+ 
metadata+=,beam-job-server-image=gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest
+ local image_version=2.0
+ echo 'Starting dataproc cluster. Dataproc version: 2.0'
Starting dataproc cluster. Dataproc version: 2.0
+ local num_dataproc_****s=6
+ gcloud dataproc clusters create beam-loadtests-go-gbk-flink-batch-480 
--region=us-central1 --num-****s=6 --metadata 
flink-snapshot-url=https://archive.apache.org/dist/flink/flink-1.12.3/flink-1.12.3-bin-scala_2.11.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_portability/beam_go_sdk:latest,beam-job-server-image=gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest,
 --image-version=2.0 --zone=us-central1-a --optional-components=FLINK,DOCKER 
--quiet
Waiting on operation 
[projects/apache-beam-testing/regions/us-central1/operations/7c213d77-8f2a-3fd7-84aa-4888a2b15088].
Waiting for cluster creation operation...
.....................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................................done.
Created 
[https://dataproc.googleapis.com/v1/projects/apache-beam-testing/regions/us-central1/clusters/beam-loadtests-go-gbk-flink-batch-480]
 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-go-gbk-flink-batch-480-m '--command=yarn application -list'
++ grep beam-loadtests-go-gbk-flink-batch-480
kex_exchange_identification: Connection closed by remote host
ERROR: (gcloud.compute.ssh) [/usr/bin/ssh] exited with return code [255].
+ read line
+ echo

++ echo
++ sed 's/ .*//'
+ application_ids[$i]=
++ echo
++ sed 
's/.*beam-loadtests-go-gbk-flink-batch-480/beam-loadtests-go-gbk-flink-batch-480/'
++ sed 's/ .*//'
+ application_masters[$i]=
+ i=1
+ read line
+ '[' 1 '!=' 1 ']'
+ YARN_APPLICATION_MASTER=
+ echo 'Using Yarn Application master: '
Using Yarn Application master: 
+ [[ -n 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest ]]
+ start_job_server
+ gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-go-gbk-flink-batch-480-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.12_job_server:latest 
--flink-master= 
--artifacts-dir=gs://beam-flink-cluster/beam-loadtests-go-gbk-flink-batch-480'
Warning: Permanently added 'compute.6972676767373691692' (ECDSA) to the list of 
known hosts.
Unable to find image 
'gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest' 
locally
latest: Pulling from 
apache-beam-testing/beam_portability/beam_flink1.12_job_server
d960726af2be: Pulling fs layer
e8d62473a22d: Pulling fs layer
8962bc0fad55: Pulling fs layer
65d943ee54c1: Pulling fs layer
da20b77f10ac: Pulling fs layer
fb6a778e6477: Pulling fs layer
ae7884f0e61b: Pulling fs layer
65d943ee54c1: Waiting
da20b77f10ac: Waiting
fb6a778e6477: Waiting
ae7884f0e61b: Waiting
6a9e39039fda: Pulling fs layer
e6b8b0d73695: Pulling fs layer
6a9e39039fda: Waiting
e6b8b0d73695: Waiting
f4af20933dae: Pulling fs layer
2bde4a20c1c6: Pulling fs layer
b5aadb375b28: Pulling fs layer
f4af20933dae: Waiting
2bde4a20c1c6: Waiting
b5aadb375b28: Waiting
8962bc0fad55: Verifying Checksum
8962bc0fad55: Download complete
e8d62473a22d: Verifying Checksum
e8d62473a22d: Download complete
da20b77f10ac: Verifying Checksum
da20b77f10ac: Download complete
fb6a778e6477: Verifying Checksum
fb6a778e6477: Download complete
d960726af2be: Verifying Checksum
d960726af2be: Download complete
6a9e39039fda: Verifying Checksum
6a9e39039fda: Download complete
65d943ee54c1: Verifying Checksum
65d943ee54c1: Download complete
f4af20933dae: Verifying Checksum
f4af20933dae: Download complete
2bde4a20c1c6: Download complete
b5aadb375b28: Verifying Checksum
b5aadb375b28: Download complete
ae7884f0e61b: Verifying Checksum
ae7884f0e61b: Download complete
e6b8b0d73695: Verifying Checksum
e6b8b0d73695: Download complete
d960726af2be: Pull complete
e8d62473a22d: Pull complete
8962bc0fad55: Pull complete
65d943ee54c1: Pull complete
da20b77f10ac: Pull complete
fb6a778e6477: Pull complete
ae7884f0e61b: Pull complete
6a9e39039fda: Pull complete
e6b8b0d73695: Pull complete
f4af20933dae: Pull complete
2bde4a20c1c6: Pull complete
b5aadb375b28: Pull complete
Digest: sha256:911283585036550af2b3ab86dd87aab88a229103f63aabf080ebec9be3589a3b
Status: Downloaded newer image for 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest
eb79395bee560b8842dfaa20e62a39e67b9f35584af380b6dc76138f9292ac3b
+ start_tunnel
++ gcloud compute ssh --quiet --zone=us-central1-a 
yarn@beam-loadtests-go-gbk-flink-batch-480-m '--command=curl -s 
"http:///jobmanager/config";'
kex_exchange_identification: read: Connection reset by peer
ERROR: (gcloud.compute.ssh) [/usr/bin/ssh] exited with return code [255].
+ local job_server_config=
+ local key=jobmanager.rpc.port
++ echo
++ cut -d : -f1
+ local yarn_application_master_host=
++ echo
++ python -c 'import sys, json; print([e['\''value'\''] for e in 
json.load(sys.stdin) if e['\''key'\''] == u'\''jobmanager.rpc.port'\''][0])'
Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "/usr/lib/python3.8/json/__init__.py", line 293, in load
    return loads(fp.read(),
  File "/usr/lib/python3.8/json/__init__.py", line 357, in loads
    return _default_decoder.decode(s)
  File "/usr/lib/python3.8/json/decoder.py", line 337, in decode
    obj, end = self.raw_decode(s, idx=_w(s, 0).end())
  File "/usr/lib/python3.8/json/decoder.py", line 355, in raw_decode
    raise JSONDecodeError("Expecting value", s, err.value) from None
json.decoder.JSONDecodeError: Expecting value: line 2 column 1 (char 1)
+ local jobmanager_rpc_port=
++ [[ true == \t\r\u\e ]]
++ echo ' -Nf >& /dev/null'
+ local 'detached_mode_params= -Nf >& /dev/null'
++ [[ -n 
gcr.io/apache-beam-testing/beam_portability/beam_flink1.12_job_server:latest ]]
++ echo '-L 8099:localhost:8099 -L 8098:localhost:8098 -L 8097:localhost:8097'
+ local 'job_server_ports_forwarding=-L 8099:localhost:8099 -L 
8098:localhost:8098 -L 8097:localhost:8097'
+ local 'tunnel_command=gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-go-gbk-flink-batch-480-m -- -L 8081: -L :: -L 
8099:localhost:8099 -L 8098:localhost:8098 -L 8097:localhost:8097 -D 1080  -Nf 
>& /dev/null'
+ eval gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-go-gbk-flink-batch-480-m -- -L 8081: -L :: -L 
8099:localhost:8099 -L 8098:localhost:8098 -L 8097:localhost:8097 -D 1080 -Nf 
'>&' /dev/null
++ gcloud compute ssh --zone=us-central1-a --quiet 
yarn@beam-loadtests-go-gbk-flink-batch-480-m -- -L 8081: -L :: -L 
8099:localhost:8099 -L 8098:localhost:8098 -L 8097:localhost:8097 -D 1080 -Nf
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