See
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/2635/display/redirect>
Changes:
------------------------------------------
[...truncated 1.25 MB...]
'simple': simple, 'enrich': enrich
}
| SqlTransform(
"""
SELECT
simple.`id` AS `id`,
enrich.metadata AS metadata
FROM simple
JOIN enrich
> ON simple.`id` = enrich.`id`"""))
apache_beam/transforms/sql_test.py:140:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/transforms/ptransform.py:614: in __ror__
result = p.apply(self, pvalueish, label)
apache_beam/pipeline.py:708: in apply
pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
apache_beam/runners/runner.py:185: in apply
return m(transform, input, options)
apache_beam/runners/runner.py:215: in apply_PTransform
return transform.expand(input)
apache_beam/transforms/external.py:523: in expand
with self._service() as service:
/usr/lib/python3.7/contextlib.py:112: in __enter__
return next(self.gen)
apache_beam/transforms/external.py:579: in _service
with self._expansion_service as stub:
apache_beam/transforms/external.py:766: in __enter__
self._service = self._service_provider.__enter__()
apache_beam/utils/subprocess_server.py:72: in __enter__
return self.start()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <apache_beam.utils.subprocess_server.JavaJarServer object at
0x7fec2df3de50>
def start(self):
try:
endpoint = self.start_process()
wait_secs = .1
channel_options = [("grpc.max_receive_message_length", -1),
("grpc.max_send_message_length", -1)]
channel = grpc.insecure_channel(endpoint, options=channel_options)
channel_ready = grpc.channel_ready_future(channel)
while True:
if self._process is not None and self._process.poll() is not None:
_LOGGER.error("Starting job service with %s", self._process.args)
raise RuntimeError(
> 'Service failed to start up with error %s' %
> self._process.poll())
E RuntimeError: Service failed to start up with error 1
apache_beam/utils/subprocess_server.py:89: RuntimeError
----------------------------- Captured stderr call -----------------------------
E0511 11:35:55.274302992 3779876 fork_posix.cc:76] Other threads are
currently calling into gRPC, skipping fork() handlers
ERROR:apache_beam.utils.subprocess_server:Starting job service with ['java',
'-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'59713',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR:apache_beam.utils.subprocess_server:Error bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
------------------------------ Captured log call -------------------------------
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:87 Starting
job service with ['java', '-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'59713',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:101 Error
bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
__________________ SqlTransformTest.test_windowing_before_sql __________________
self = <apache_beam.transforms.sql_test.SqlTransformTest
testMethod=test_windowing_before_sql>
def test_windowing_before_sql(self):
with TestPipeline() as p:
out = (
p | beam.Create([
SimpleRow(5, "foo", 1.),
SimpleRow(15, "bar", 2.),
SimpleRow(25, "baz", 3.)
])
| beam.Map(lambda v: beam.window.TimestampedValue(v, v.id)).
with_output_types(SimpleRow)
| beam.WindowInto(
beam.window.FixedWindows(10)).with_output_types(SimpleRow)
> | SqlTransform("SELECT COUNT(*) as `count` FROM PCOLLECTION"))
apache_beam/transforms/sql_test.py:174:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/pvalue.py:137: in __or__
return self.pipeline.apply(ptransform, self)
apache_beam/pipeline.py:708: in apply
pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
apache_beam/runners/runner.py:185: in apply
return m(transform, input, options)
apache_beam/runners/runner.py:215: in apply_PTransform
return transform.expand(input)
apache_beam/transforms/external.py:523: in expand
with self._service() as service:
/usr/lib/python3.7/contextlib.py:112: in __enter__
return next(self.gen)
apache_beam/transforms/external.py:579: in _service
with self._expansion_service as stub:
apache_beam/transforms/external.py:766: in __enter__
self._service = self._service_provider.__enter__()
apache_beam/utils/subprocess_server.py:72: in __enter__
return self.start()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <apache_beam.utils.subprocess_server.JavaJarServer object at
0x7fec2e023810>
def start(self):
try:
endpoint = self.start_process()
wait_secs = .1
channel_options = [("grpc.max_receive_message_length", -1),
("grpc.max_send_message_length", -1)]
channel = grpc.insecure_channel(endpoint, options=channel_options)
channel_ready = grpc.channel_ready_future(channel)
while True:
if self._process is not None and self._process.poll() is not None:
_LOGGER.error("Starting job service with %s", self._process.args)
raise RuntimeError(
> 'Service failed to start up with error %s' %
> self._process.poll())
E RuntimeError: Service failed to start up with error 1
apache_beam/utils/subprocess_server.py:89: RuntimeError
----------------------------- Captured stderr call -----------------------------
E0511 11:35:55.699820062 3779876 fork_posix.cc:76] Other threads are
currently calling into gRPC, skipping fork() handlers
ERROR:apache_beam.utils.subprocess_server:Starting job service with ['java',
'-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'38599',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR:apache_beam.utils.subprocess_server:Error bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
------------------------------ Captured log call -------------------------------
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:87 Starting
job service with ['java', '-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'38599',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:101 Error
bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
_________________ SqlTransformTest.test_zetasql_generate_data __________________
self = <apache_beam.transforms.sql_test.SqlTransformTest
testMethod=test_zetasql_generate_data>
def test_zetasql_generate_data(self):
with TestPipeline() as p:
out = p | SqlTransform(
"""SELECT
CAST(1 AS INT64) AS `int`,
CAST('foo' AS STRING) AS `str`,
CAST(3.14 AS FLOAT64) AS `flt`""",
> dialect="zetasql")
apache_beam/transforms/sql_test.py:159:
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
apache_beam/transforms/ptransform.py:614: in __ror__
result = p.apply(self, pvalueish, label)
apache_beam/pipeline.py:708: in apply
pvalueish_result = self.runner.apply(transform, pvalueish, self._options)
apache_beam/runners/runner.py:185: in apply
return m(transform, input, options)
apache_beam/runners/runner.py:215: in apply_PTransform
return transform.expand(input)
apache_beam/transforms/external.py:523: in expand
with self._service() as service:
/usr/lib/python3.7/contextlib.py:112: in __enter__
return next(self.gen)
apache_beam/transforms/external.py:579: in _service
with self._expansion_service as stub:
apache_beam/transforms/external.py:766: in __enter__
self._service = self._service_provider.__enter__()
apache_beam/utils/subprocess_server.py:72: in __enter__
return self.start()
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _
self = <apache_beam.utils.subprocess_server.JavaJarServer object at
0x7fec2def9090>
def start(self):
try:
endpoint = self.start_process()
wait_secs = .1
channel_options = [("grpc.max_receive_message_length", -1),
("grpc.max_send_message_length", -1)]
channel = grpc.insecure_channel(endpoint, options=channel_options)
channel_ready = grpc.channel_ready_future(channel)
while True:
if self._process is not None and self._process.poll() is not None:
_LOGGER.error("Starting job service with %s", self._process.args)
raise RuntimeError(
> 'Service failed to start up with error %s' %
> self._process.poll())
E RuntimeError: Service failed to start up with error 1
apache_beam/utils/subprocess_server.py:89: RuntimeError
----------------------------- Captured stderr call -----------------------------
E0511 11:35:55.830728115 3779876 fork_posix.cc:76] Other threads are
currently calling into gRPC, skipping fork() handlers
ERROR:apache_beam.utils.subprocess_server:Starting job service with ['java',
'-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'39025',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR:apache_beam.utils.subprocess_server:Error bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
------------------------------ Captured log call -------------------------------
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:87 Starting
job service with ['java', '-jar',
'<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar',>
'39025',
'--filesToStage=<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/java/extensions/sql/expansion-service/build/libs/beam-sdks-java-extensions-sql-expansion-service-2.40.0-SNAPSHOT.jar']>
ERROR apache_beam.utils.subprocess_server:subprocess_server.py:101 Error
bringing up service
Traceback (most recent call last):
File
"<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/apache_beam/utils/subprocess_server.py",>
line 89, in start
'Service failed to start up with error %s' % self._process.poll())
RuntimeError: Service failed to start up with error 1
- generated xml file:
<https://ci-beam.apache.org/job/beam_PostCommit_XVR_Direct/ws/src/sdks/python/pytest_xlangSqlValidateRunner.xml>
-
============ 9 failed, 1 skipped, 5566 deselected in 11.96 seconds =============
> Task
> :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerPythonUsingSql
> FAILED
> Task :sdks:python:test-suites:direct:xlang:validatesCrossLanguageRunnerCleanup
Stopping expansion service pid: 3748656.
Stopping expansion service pid: 3748657.
> Task :sdks:python:test-suites:direct:xlang:fnApiJobServerCleanup
Killing process at 3740235
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task
':sdks:python:test-suites:direct:xlang: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 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
Execution optimizations have been disabled for 1 invalid unit(s) of work during
this build to ensure correctness.
Please consult deprecation warnings for more details.
BUILD FAILED in 25m 34s
233 actionable tasks: 154 executed, 68 from cache, 11 up-to-date
Publishing build scan...
https://gradle.com/s/zh65ixns7guni
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]