See <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/2810/display/redirect?page=changes>
Changes: [bulat.safiullin] [Website] change case studies link from staging to relative path [bulat.safiullin] [Website] add I/O Connectors link to dropdown list, updating link to [relax] set timestamp when outputting finalize element [alexey.inkin] Declarative theming, Remove duplicate PlaygroundState for embedded page, [yathu] Fix Hadoop upload corrupted due to buffer reuse [benjamin.gonzalez] Fix testKafkaIOReadsAndWritesCorrectlyInStreaming failing for kafka [noreply] Optimize locking in several critical-path methods (#22162) [noreply] Deprecate AWS IOs (Java) using AWS SDK v1 in favor of IOs in [noreply] Update Go BPG xlang documentation to include Java automated service [noreply] Merge pull request #22096 from [Playground] Infrastructure for sharing [noreply] Support dependencies and remote registration in the typescript SDK. [noreply] [BEAM-13015, #22050] Make SDK harness msec counters faster using ordered [yathu] Fix build error due to dep confliction of google-cloud-bigquery-storage [yathu] Fix atomicwrites old version purge on pypi [noreply] Fix default type inference of CombinePerKey. (#16351) [noreply] Add typescript documentation to the programing guide. (#22137) [noreply] [Website] Update minimum required Go version for sdk development [noreply] Parallelizable DataFrame/Series mean (#22174) [noreply] Split checkStyle from precommit into spotless job (#22203) [noreply] Allow one to bound the size of output shards when writing to files. [noreply] Bump moment from 2.29.2 to 2.29.4 in [noreply] Allow BigQuery TableIds to have space in between (#22167) [noreply] Use async as a suffix rather than a prefix for asynchronous variants. ------------------------------------------ [...truncated 16.86 KB...] + read -r usedPort + '[' 32404 = 30544 ']' + IFS= + read -r usedPort + '[' 32404 = 30695 ']' + IFS= + read -r usedPort + '[' 32404 = 30706 ']' + IFS= + read -r usedPort + '[' 32404 = 31851 ']' + IFS= + read -r usedPort + '[' 32404 = 31058 ']' + IFS= + read -r usedPort + '[' 32404 = 31659 ']' + IFS= + read -r usedPort + '[' 32404 = 31005 ']' + IFS= + read -r usedPort + '[' 32404 = 32267 ']' + IFS= + read -r usedPort + '[' 32404 = 31425 ']' + IFS= + read -r usedPort + '[' 32404 = 32402 ']' + IFS= + read -r usedPort + '[' 32404 = 31333 ']' + IFS= + read -r usedPort + '[' 32404 = 30251 ']' + IFS= + read -r usedPort + '[' 32404 = 31035 ']' + IFS= + read -r usedPort + '[' 32404 = 31605 ']' + IFS= + read -r usedPort + '[' 32404 = 31565 ']' + IFS= + read -r usedPort + '[' 32404 = 30885 ']' + IFS= + read -r usedPort + '[' 32404 = 30673 ']' + IFS= + read -r usedPort + '[' 32404 = 32219 ']' + IFS= + read -r usedPort + '[' 32404 = 30855 ']' + IFS= + read -r usedPort + '[' 32404 = 30419 ']' + IFS= + read -r usedPort + '[' 32404 = 30746 ']' + IFS= + read -r usedPort + '[' 32404 = 32491 ']' + IFS= + read -r usedPort + '[' 32404 = 32676 ']' + IFS= + read -r usedPort + '[' 32404 = 31352 ']' + IFS= + read -r usedPort + '[' 32404 = 31977 ']' + IFS= + read -r usedPort + false + echo 32404 + return 0 [EnvInject] - Injecting environment variables from a build step. [EnvInject] - Injecting as environment variables the properties file path 'job.properties' [EnvInject] - Variables injected successfully. [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins607181573896174669.sh + sed -i -e s/32400/32401/ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster/04-outside-services/outside-0.yml> [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins1605113916648207899.sh + sed -i -e s/32401/32403/ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster/04-outside-services/outside-1.yml> [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins4107078770021434256.sh + sed -i -e s/32402/32404/ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster/04-outside-services/outside-2.yml> [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins1179350689729110927.sh + <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> apply <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster> + KUBECONFIG=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> + KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-2810 + KUBECTL='kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810' + apply <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster> + eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 apply -R -f <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster'> ++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 apply -R -f <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kafka-cluster> storageclass.storage.k8s.io/kafka-broker unchanged storageclass.storage.k8s.io/kafka-zookeeper unchanged clusterrole.rbac.authorization.k8s.io/node-reader unchanged clusterrolebinding.rbac.authorization.k8s.io/kafka-node-reader configured role.rbac.authorization.k8s.io/pod-labler created rolebinding.rbac.authorization.k8s.io/kafka-pod-labler created configmap/zookeeper-config created service/pzoo created service/zookeeper created statefulset.apps/pzoo created service/outside-0 created service/outside-1 created service/outside-2 created configmap/broker-config created service/broker created service/bootstrap created statefulset.apps/kafka created configmap/kafka-config created job.batch/kafka-config-eff079ec created [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins3356918570390304984.sh + set -eo pipefail + eval <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-0 ++ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-0 + KUBECONFIG=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> + KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-2810 + KUBECTL='kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810' + loadBalancerIP outside-0 + local name=outside-0 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + retry 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' 36 10 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + local max_retries=36 + local sleep_time=10 + (( i = 1 )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + sed 's/^/KAFKA_BROKER_0=/' + output= + local status=0 + [[ 0 == 0 ]] + [[ -n '' ]] + [[ 1 == \3\6 ]] + sleep 10 + (( i++ )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + output= + local status=0 + [[ 0 == 0 ]] + [[ -n '' ]] + [[ 2 == \3\6 ]] + sleep 10 + (( i++ )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + output= + local status=0 + [[ 0 == 0 ]] + [[ -n '' ]] + [[ 3 == \3\6 ]] + sleep 10 + (( i++ )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-0 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + output=34.69.130.106 + local status=0 + [[ 0 == 0 ]] + [[ -n 34.69.130.106 ]] + echo 34.69.130.106 + return 0 [EnvInject] - Injecting environment variables from a build step. [EnvInject] - Injecting as environment variables the properties file path 'job.properties' [EnvInject] - Variables injected successfully. [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins6490486079060994358.sh + set -eo pipefail + eval <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-1 ++ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-1 + sed 's/^/KAFKA_BROKER_1=/' + KUBECONFIG=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> + KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-2810 + KUBECTL='kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810' + loadBalancerIP outside-1 + local name=outside-1 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-1 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + retry 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-1 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' 36 10 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-1 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + local max_retries=36 + local sleep_time=10 + (( i = 1 )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-1 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-1 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + output=34.67.151.211 + local status=0 + [[ 0 == 0 ]] + [[ -n 34.67.151.211 ]] + echo 34.67.151.211 + return 0 [EnvInject] - Injecting environment variables from a build step. [EnvInject] - Injecting as environment variables the properties file path 'job.properties' [EnvInject] - Variables injected successfully. [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins8432331788603602588.sh + set -eo pipefail + eval <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-2 ++ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> loadBalancerIP outside-2 + sed 's/^/KAFKA_BROKER_2=/' + KUBECONFIG=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> + KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-2810 + KUBECTL='kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810' + loadBalancerIP outside-2 + local name=outside-2 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-2 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + retry 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-2 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' 36 10 + local 'command=kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-2 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' + local max_retries=36 + local sleep_time=10 + (( i = 1 )) + (( i <= max_retries )) + local output ++ eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-2 -ojsonpath='\''{.status.loadBalancer.ingress[0].ip}'\''' +++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 get svc outside-2 '-ojsonpath={.status.loadBalancer.ingress[0].ip}' + output=34.135.98.164 + local status=0 + [[ 0 == 0 ]] + [[ -n 34.135.98.164 ]] + echo 34.135.98.164 + return 0 [EnvInject] - Injecting environment variables from a build step. [EnvInject] - Injecting as environment variables the properties file path 'job.properties' [EnvInject] - Variables injected successfully. [beam_PerformanceTests_Kafka_IO] $ /bin/bash -xe /tmp/jenkins943036780561134867.sh + eval <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> waitForJob job.batch/kafka-config-eff079ec 40m ++ <https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/src/.test-infra/kubernetes/kubernetes.sh> waitForJob job.batch/kafka-config-eff079ec 40m + KUBECONFIG=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> + KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-2810 + KUBECTL='kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810' + waitForJob job.batch/kafka-config-eff079ec 40m + echo 'Waiting for job completion...' Waiting for job completion... + jobName=job.batch/kafka-config-eff079ec + eval 'kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 wait --for=condition=complete --timeout=40m job.batch/kafka-config-eff079ec' ++ kubectl --kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-2810> --namespace=beam-performancetests-kafka-io-2810 wait --for=condition=complete --timeout=40m job.batch/kafka-config-eff079ec error: timed out waiting for the condition on jobs/kafka-config-eff079ec Build step 'Execute shell' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
