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]

Reply via email to