See <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/2912/display/redirect>
Changes: ------------------------------------------ [...truncated 703.23 KB...] until = None if timeout is None else time.time() + timeout with self._condition: while True: if self._cancelled: raise grpc.FutureCancelledError() elif self._matured: return else: if until is None: self._condition.wait() else: remaining = until - time.time() if remaining < 0: > raise grpc.FutureTimeoutError() E grpc.FutureTimeoutError ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:85: FutureTimeoutError ----------------------------- Captured stderr call ----------------------------- WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. ------------------------------ Captured log call ------------------------------- WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. ______________________ SqlTransformTest.test_tagged_join _______________________ self = <apache_beam.transforms.sql_test.SqlTransformTest testMethod=test_tagged_join> def test_tagged_join(self): with TestPipeline() as p: enrich = ( p | "Create enrich" >> beam.Create( [Enrich(1, "a"), Enrich(2, "b"), Enrich(26, "z")])) simple = ( p | "Create simple" >> beam.Create([ SimpleRow(1, "foo", 3.14), SimpleRow(26, "bar", 1.11), SimpleRow(1, "baz", 2.34) ])) out = ({ 'simple': simple, 'enrich': enrich } | SqlTransform( """ SELECT simple.`id` AS `id`, enrich.metadata AS metadata FROM simple JOIN enrich ON simple.`id` = enrich.`id`""")) > assert_that(out, equal_to([(1, "a"), (26, "z"), (1, "a")])) apache_beam/transforms/sql_test.py:141: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ apache_beam/pipeline.py:596: in __exit__ self.result = self.run() apache_beam/testing/test_pipeline.py:114: in run False if self.not_use_test_runner_api else test_runner_api)) apache_beam/pipeline.py:573: in run return self.runner.run_pipeline(self, self._options) apache_beam/runners/portability/portable_runner.py:438: in run_pipeline job_service_handle = self.create_job_service(options) apache_beam/runners/portability/portable_runner.py:317: in create_job_service return self.create_job_service_handle(server.start(), options) apache_beam/runners/portability/job_server.py:54: in start grpc.channel_ready_future(channel).result(timeout=self._timeout) ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:139: in result self._block(timeout) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <grpc._utilities._ChannelReadyFuture object at 0x7f1261225c18> timeout = 60 def _block(self, timeout): until = None if timeout is None else time.time() + timeout with self._condition: while True: if self._cancelled: raise grpc.FutureCancelledError() elif self._matured: return else: if until is None: self._condition.wait() else: remaining = until - time.time() if remaining < 0: > raise grpc.FutureTimeoutError() E grpc.FutureTimeoutError ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:85: FutureTimeoutError ----------------------------- Captured stderr call ----------------------------- WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. ------------------------------ Captured log call ------------------------------- WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. __________________ 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")) > assert_that(out, equal_to([(1, ), (1, ), (1, )])) apache_beam/transforms/sql_test.py:175: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ apache_beam/pipeline.py:596: in __exit__ self.result = self.run() apache_beam/testing/test_pipeline.py:114: in run False if self.not_use_test_runner_api else test_runner_api)) apache_beam/pipeline.py:573: in run return self.runner.run_pipeline(self, self._options) apache_beam/runners/portability/portable_runner.py:438: in run_pipeline job_service_handle = self.create_job_service(options) apache_beam/runners/portability/portable_runner.py:317: in create_job_service return self.create_job_service_handle(server.start(), options) apache_beam/runners/portability/job_server.py:54: in start grpc.channel_ready_future(channel).result(timeout=self._timeout) ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:139: in result self._block(timeout) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <grpc._utilities._ChannelReadyFuture object at 0x7f12544e0908> timeout = 60 def _block(self, timeout): until = None if timeout is None else time.time() + timeout with self._condition: while True: if self._cancelled: raise grpc.FutureCancelledError() elif self._matured: return else: if until is None: self._condition.wait() else: remaining = until - time.time() if remaining < 0: > raise grpc.FutureTimeoutError() E grpc.FutureTimeoutError ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:85: FutureTimeoutError ----------------------------- Captured stderr call ----------------------------- WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. ------------------------------ Captured log call ------------------------------- WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. _________________ 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") > assert_that(out, equal_to([(1, "foo", 3.14)])) apache_beam/transforms/sql_test.py:160: _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ apache_beam/pipeline.py:596: in __exit__ self.result = self.run() apache_beam/testing/test_pipeline.py:114: in run False if self.not_use_test_runner_api else test_runner_api)) apache_beam/pipeline.py:573: in run return self.runner.run_pipeline(self, self._options) apache_beam/runners/portability/portable_runner.py:438: in run_pipeline job_service_handle = self.create_job_service(options) apache_beam/runners/portability/portable_runner.py:317: in create_job_service return self.create_job_service_handle(server.start(), options) apache_beam/runners/portability/job_server.py:54: in start grpc.channel_ready_future(channel).result(timeout=self._timeout) ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:139: in result self._block(timeout) _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ self = <grpc._utilities._ChannelReadyFuture object at 0x7f1255e15b70> timeout = 60 def _block(self, timeout): until = None if timeout is None else time.time() + timeout with self._condition: while True: if self._cancelled: raise grpc.FutureCancelledError() elif self._matured: return else: if until is None: self._condition.wait() else: remaining = until - time.time() if remaining < 0: > raise grpc.FutureTimeoutError() E grpc.FutureTimeoutError ../../build/gradleenv/1922375555/lib/python3.6/site-packages/grpc/_utilities.py:85: FutureTimeoutError ----------------------------- Captured stderr call ----------------------------- WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING:root:Make sure that locally built Python SDK docker image has Python 3.6 interpreter. ------------------------------ Captured log call ------------------------------- WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. WARNING root:environments.py:374 Make sure that locally built Python SDK docker image has Python 3.6 interpreter. - generated xml file: <https://ci-beam.apache.org/job/beam_PostCommit_XVR_Spark/ws/src/sdks/python/pytest_xlangSqlValidateRunner.xml> - ============ 7 failed, 2 passed, 5088 deselected in 535.26 seconds ============= > Task :runners:spark:2:job-server:validatesCrossLanguageRunnerPythonUsingSql > FAILED > Task :runners:spark:2:job-server:validatesCrossLanguageRunnerCleanup > Task :runners:spark:2:job-server:sparkJobServerCleanup FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':runners:spark:2: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.9.1/userguide/command_line_interface.html#sec:command_line_warnings BUILD FAILED in 42m 27s 216 actionable tasks: 154 executed, 55 from cache, 7 up-to-date Publishing build scan... https://gradle.com/s/2oabptwhh6nn2 Build step 'Invoke Gradle script' changed build result to FAILURE Build step 'Invoke Gradle script' marked build as failure --------------------------------------------------------------------- To unsubscribe, e-mail: builds-unsubscr...@beam.apache.org For additional commands, e-mail: builds-h...@beam.apache.org