See
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/1822/display/redirect>
Changes:
------------------------------------------
[...truncated 232.96 KB...]
DEBUG:root:Waiting for grpc channel to be ready at localhost:33005.
DEBUG:root:Waiting for grpc channel to be ready at localhost:33005.
DEBUG:root:Waiting for grpc channel to be ready at localhost:33005.
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:31:43 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand'
INFO:apache_beam.utils.subprocess_server:b"INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'"
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:31:44 PM
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
payloadToConfig'
INFO:apache_beam.utils.subprocess_server:b"WARNING: Configuration class
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
has no schema registered. Attempting to construct with setter approach."
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:31:46 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel'
INFO:apache_beam.utils.subprocess_server:b'INFO: SQL:'
INFO:apache_beam.utils.subprocess_server:b'SELECT COUNT(*) AS `count`'
INFO:apache_beam.utils.subprocess_server:b'FROM `beam`.`PCOLLECTION` AS
`PCOLLECTION`'
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:31:46 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel'
INFO:apache_beam.utils.subprocess_server:b'INFO: SQLPlan>'
INFO:apache_beam.utils.subprocess_server:b'LogicalAggregate(group=[{}],
count=[COUNT()])'
INFO:apache_beam.utils.subprocess_server:b' LogicalProject($f0=[0])'
INFO:apache_beam.utils.subprocess_server:b' BeamIOSourceRel(table=[[beam,
PCOLLECTION]])'
INFO:apache_beam.utils.subprocess_server:b''
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:31:46 PM
org.apache.beam.sdk.extensions.sql.impl.CalciteQueryPlanner convertToBeamRel'
INFO:apache_beam.utils.subprocess_server:b'INFO: BEAMPlan>'
INFO:apache_beam.utils.subprocess_server:b'BeamAggregationRel(group=[{}],
count=[COUNT()])'
INFO:apache_beam.utils.subprocess_server:b' BeamIOSourceRel(table=[[beam,
PCOLLECTION]])'
INFO:apache_beam.utils.subprocess_server:b''
DEBUG:root:Sending SIGINT to job_server
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
INFO:root:No image given, using default Python SDK image
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
INFO:root:Python SDK container image set to
"apache/beam_python3.6_sdk:2.28.0.dev" for Docker environment
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'dataflow_kms_key' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'enable_streaming_engine' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'project'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_region' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_zone' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'zone' was
already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'pubsub_root_url' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'job_name'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'runner'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'temp_location' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'streaming'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'environment_cache_millis' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'job_endpoint' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'output_executable_path' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'sdk_worker_parallelism' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'files_to_stage' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'flink_master' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'experiments' was already added
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to DONE
ok
test_zetasql_generate_data (apache_beam.transforms.sql_test.SqlTransformTest)
... INFO:apache_beam.utils.subprocess_server:Using pre-built snapshot at
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.28.0-SNAPSHOT.jar>
INFO:apache_beam.utils.subprocess_server:Starting service with ['java' '-jar'
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.28.0-SNAPSHOT.jar'>
'49769']
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
INFO:apache_beam.utils.subprocess_server:b'Starting expansion service at
localhost:49769'
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:32:06 PM
org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms'
INFO:apache_beam.utils.subprocess_server:b'INFO: Registering external
transforms: [beam:external:java:sql:v1,
beam:external:java:generate_sequence:v1]'
INFO:apache_beam.utils.subprocess_server:b'\tbeam:external:java:sql:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$3/1130478920@5680a178'
INFO:apache_beam.utils.subprocess_server:b'\tbeam:external:java:generate_sequence:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$3/1130478920@5fdef03a'
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
DEBUG:root:Waiting for grpc channel to be ready at localhost:49769.
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:32:07 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand'
INFO:apache_beam.utils.subprocess_server:b"INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'"
INFO:apache_beam.utils.subprocess_server:b'Jan 15, 2021 6:32:08 PM
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
payloadToConfig'
INFO:apache_beam.utils.subprocess_server:b"WARNING: Configuration class
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
has no schema registered. Attempting to construct with setter approach."
DEBUG:root:Sending SIGINT to job_server
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
DEBUG:root:Unhandled type_constraint: Union[]
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
INFO:root:No image given, using default Python SDK image
WARNING:root:Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
INFO:root:Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
INFO:root:Python SDK container image set to
"apache/beam_python3.6_sdk:2.28.0.dev" for Docker environment
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'dataflow_kms_key' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'enable_streaming_engine' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'project'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_region' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'worker_zone' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'zone' was
already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'pubsub_root_url' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'job_name'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'runner'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'temp_location' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option 'streaming'
was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'environment_cache_millis' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'job_endpoint' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'output_executable_path' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'sdk_worker_parallelism' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'files_to_stage' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'flink_master' was already added
DEBUG:apache_beam.runners.portability.portable_runner:Runner option
'experiments' was already added
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STOPPED
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
STARTING
INFO:apache_beam.runners.portability.portable_runner:Job state changed to
RUNNING
Exception in thread wait_until_finish_read:
Traceback (most recent call last):
File "/usr/lib/python3.6/threading.py", line 916, in _bootstrap_inner
self.run()
File "/usr/lib/python3.6/threading.py", line 864, in run
self._target(*self._args, **self._kwargs)
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
line 546, in read_messages
for message in self._message_stream:
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_channel.py";,>
line 416, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_channel.py";,>
line 803, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1610735548.261556709","description":"Error received from peer
ipv4:127.0.0.1:18091","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Socket
closed","grpc_status":14}"
>
ERROR
======================================================================
ERROR: test_zetasql_generate_data
(apache_beam.transforms.sql_test.SqlTransformTest)
----------------------------------------------------------------------
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/transforms/sql_test.py";,>
line 164, in test_zetasql_generate_data
assert_that(out, equal_to([(1, "foo", 3.14)]))
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/pipeline.py";,>
line 580, in __exit__
self.result = self.run()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/testing/test_pipeline.py";,>
line 114, in run
state = result.wait_until_finish()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
line 581, in wait_until_finish
raise self._runtime_exception
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/apache_beam/runners/portability/portable_runner.py";,>
line 587, in _observe_state
for state_response in self._state_stream:
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_channel.py";,>
line 416, in __next__
return self._next()
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_channel.py";,>
line 803, in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.UNAVAILABLE
details = "Socket closed"
debug_error_string =
"{"created":"@1610735548.261533691","description":"Error received from peer
ipv4:127.0.0.1:18091","file":"src/core/lib/surface/call.cc","file_line":1062,"grpc_message":"Socket
closed","grpc_status":14}"
>
-------------------- >> begin captured logging << --------------------
apache_beam.utils.subprocess_server: INFO: Using pre-built snapshot at
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.28.0-SNAPSHOT.jar>
apache_beam.utils.subprocess_server: INFO: Starting service with ['java' '-jar'
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.28.0-SNAPSHOT.jar'>
'49769']
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
apache_beam.utils.subprocess_server: INFO: b'Starting expansion service at
localhost:49769'
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
apache_beam.utils.subprocess_server: INFO: b'Jan 15, 2021 6:32:06 PM
org.apache.beam.sdk.expansion.service.ExpansionService loadRegisteredTransforms'
apache_beam.utils.subprocess_server: INFO: b'INFO: Registering external
transforms: [beam:external:java:sql:v1,
beam:external:java:generate_sequence:v1]'
apache_beam.utils.subprocess_server: INFO: b'\tbeam:external:java:sql:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$3/1130478920@5680a178'
apache_beam.utils.subprocess_server: INFO:
b'\tbeam:external:java:generate_sequence:v1:
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader$$Lambda$3/1130478920@5fdef03a'
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
root: DEBUG: Waiting for grpc channel to be ready at localhost:49769.
apache_beam.utils.subprocess_server: INFO: b'Jan 15, 2021 6:32:07 PM
org.apache.beam.sdk.expansion.service.ExpansionService expand'
apache_beam.utils.subprocess_server: INFO: b"INFO: Expanding
'SqlTransform(beam:external:java:sql:v1)' with URN 'beam:external:java:sql:v1'"
apache_beam.utils.subprocess_server: INFO: b'Jan 15, 2021 6:32:08 PM
org.apache.beam.sdk.expansion.service.ExpansionService$ExternalTransformRegistrarLoader
payloadToConfig'
apache_beam.utils.subprocess_server: INFO: b"WARNING: Configuration class
'org.apache.beam.sdk.extensions.sql.expansion.ExternalSqlTransformRegistrar$Configuration'
has no schema registered. Attempting to construct with setter approach."
root: DEBUG: Sending SIGINT to job_server
root: DEBUG: Unhandled type_constraint: Union[]
root: DEBUG: Unhandled type_constraint: Union[]
root: DEBUG: Unhandled type_constraint: Union[]
root: DEBUG: Unhandled type_constraint: Union[]
root: WARNING: Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
root: INFO: Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
root: INFO: No image given, using default Python SDK image
root: WARNING: Make sure that locally built Python SDK docker image has Python
3.6 interpreter.
root: INFO: Default Python SDK image for environment is
apache/beam_python3.6_sdk:2.28.0.dev
root: INFO: Python SDK container image set to
"apache/beam_python3.6_sdk:2.28.0.dev" for Docker environment
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'dataflow_kms_key' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'enable_streaming_engine' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option 'project'
was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'worker_region' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'worker_zone' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option 'zone'
was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'pubsub_root_url' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'job_name' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option 'runner'
was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'temp_location' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'streaming' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'environment_cache_millis' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'job_endpoint' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'output_executable_path' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'sdk_worker_parallelism' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'files_to_stage' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'flink_master' was already added
apache_beam.runners.portability.portable_runner: DEBUG: Runner option
'experiments' was already added
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
STOPPED
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
STARTING
apache_beam.runners.portability.portable_runner: INFO: Job state changed to
RUNNING
--------------------- >> end captured logging << ---------------------
----------------------------------------------------------------------
XML: nosetests-xlangSqlValidateRunner.xml
----------------------------------------------------------------------
XML:
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/nosetests.xml>
----------------------------------------------------------------------
Ran 9 tests in 213.954s
FAILED (errors=1)
> Task :runners:spark:job-server:validatesCrossLanguageRunnerPythonUsingSql
> FAILED
> Task :runners:spark:job-server:sparkJobServerCleanup
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task
':runners:spark:job-server:validatesCrossLanguageRunnerPythonUsingPython'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* What went wrong:
Execution failed for task
':runners:spark:job-server:validatesCrossLanguageRunnerPythonUsingSql'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
Run with --stacktrace option to get the stack trace. Run with --info or --debug
option to get more log output. Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 7.0.
Use '--warning-mode all' to show the individual deprecation warnings.
See
https://docs.gradle.org/6.7.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 31m 23s
187 actionable tasks: 133 executed, 50 from cache, 4 up-to-date
Gradle was unable to watch the file system for changes. The inotify watches
limit is too low.
Publishing build scan...
https://gradle.com/s/l4s4mevf7vwpa
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
