See 
<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/3007/display/redirect?page=changes>

Changes:

[yathu] Support Timestamp type in xlang JDBC Read and Write

[yathu] change urn name to millis_instant:v1

[yathu] Add standard_coders test

[yathu] Apply suggestions from code review

[yathu] Fix Java standard coder test

[yathu] Fix logical type with same language type gets completely hidden

[noreply] Bump up postcommit timeout (#22937)

[noreply] Handle stateful windows correctly + integration test (#22918)

[noreply] Automatically infer state keys from their field name (#22922)


------------------------------------------
[...truncated 33.07 KB...]
+ local 'command=kubectl 
--kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-1 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=34.134.165.172
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n 34.134.165.172 ]]
+ echo 34.134.165.172
+ 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/jenkins6440862589003797967.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-3007>
+ KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-3007
+ KUBECTL='kubectl 
--kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-3007>
 --namespace=beam-performancetests-kafka-io-3007'
+ 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 4 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 5 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 6 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 7 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 8 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 9 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 10 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 11 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 12 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 13 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 14 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 15 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 16 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n '' ]]
+ [[ 17 == \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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 get svc outside-2 
'-ojsonpath={.status.loadBalancer.ingress[0].ip}'
+ output=34.123.234.228
+ local status=0
+ [[ 0 == 0 ]]
+ [[ -n 34.123.234.228 ]]
+ echo 34.123.234.228
+ 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/jenkins6618630093902214747.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-3007>
+ KUBERNETES_NAMESPACE=beam-performancetests-kafka-io-3007
+ KUBECTL='kubectl 
--kubeconfig=<https://ci-beam.apache.org/job/beam_PerformanceTests_Kafka_IO/ws/config-beam-performancetests-kafka-io-3007>
 --namespace=beam-performancetests-kafka-io-3007'
+ 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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-3007>
 --namespace=beam-performancetests-kafka-io-3007 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]

Reply via email to