See <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/497/display/redirect>
Changes: ------------------------------------------ [...truncated 1.83 MB...] apache_beam/runners/portability/portable_runner_test.py::PortableRunnerTestWithLocalDocker::test_error_traceback_includes_user_code <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/_pytest/threadexception.py>:73: PytestUnhandledThreadExceptionWarning: Exception in thread Thread-2103 (_run_job) Traceback (most recent call last): File "apache_beam/runners/common.py", line 1418, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 625, in apache_beam.runners.common.SimpleInvoker.invoke_process windowed_value, self.process_method(windowed_value.value)) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/transforms/core.py";,> line -1, in <lambda> File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line 1349, in first assert_that( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line 1350, in second pcoll | 'PackableMax' >> beam.CombineGlobally(max_with_counter), File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line -1, in third ValueError: This error is expected and does not indicate a test failure. During handling of the above exception, another exception occurred: Traceback (most recent call last): File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner self.run() File "/usr/lib/python3.10/threading.py", line 946, in run self._target(*self._args, **self._kwargs) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/local_job_service.py";,> line 296, in _run_job self.result = self._invoke_runner() File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/local_job_service.py";,> line 319, in _invoke_runner provision_info=self._provision_info).run_via_runner_api( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 224, in run_via_runner_api return self.run_stages(stage_context, stages) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 455, in run_stages bundle_results = self._execute_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 783, in _execute_bundle self._run_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1012, in _run_bundle result, splits = bundle_manager.process_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1348, in process_bundle result_future = self._worker_handler.control_conn.push(process_bundle_req) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py";,> line 379, in push response = self.worker.do_instruction(request) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 629, in do_instruction return getattr(self, request_type)( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 667, in process_bundle bundle_processor.process_bundle(instruction_id)) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1062, in process_bundle input_op_by_transform_id[element.transform_id].process_encoded( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 232, in process_encoded self.output(decoded_value) File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output def output(self, windowed_value, output_index=0): File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output _cast_to_receiver(self.receivers[output_index]).receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive def receive(self, windowed_value): File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process delayed_applications = self.dofn_runner.process(o) File "apache_beam/runners/common.py", line 1420, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 1492, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise exn File "apache_beam/runners/common.py", line 1418, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process self.output_handler.handle_process_outputs( File "apache_beam/runners/common.py", line 1582, in apache_beam.runners.common._OutputHandler.handle_process_outputs self._write_value_to_tag(tag, windowed_value, watermark_estimator) File "apache_beam/runners/common.py", line 1695, in apache_beam.runners.common._OutputHandler._write_value_to_tag self.main_receivers.receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process delayed_applications = self.dofn_runner.process(o) File "apache_beam/runners/common.py", line 1420, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 1492, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise exn File "apache_beam/runners/common.py", line 1418, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 624, in apache_beam.runners.common.SimpleInvoker.invoke_process self.output_handler.handle_process_outputs( File "apache_beam/runners/common.py", line 1582, in apache_beam.runners.common._OutputHandler.handle_process_outputs self._write_value_to_tag(tag, windowed_value, watermark_estimator) File "apache_beam/runners/common.py", line 1695, in apache_beam.runners.common._OutputHandler._write_value_to_tag self.main_receivers.receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 907, in apache_beam.runners.worker.operations.DoOperation.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 908, in apache_beam.runners.worker.operations.DoOperation.process delayed_applications = self.dofn_runner.process(o) File "apache_beam/runners/common.py", line 1420, in apache_beam.runners.common.DoFnRunner.process self._reraise_augmented(exn) File "apache_beam/runners/common.py", line 1508, in apache_beam.runners.common.DoFnRunner._reraise_augmented raise new_exn.with_traceback(tb) File "apache_beam/runners/common.py", line 1418, in apache_beam.runners.common.DoFnRunner.process return self.do_fn_invoker.invoke_process(windowed_value) File "apache_beam/runners/common.py", line 625, in apache_beam.runners.common.SimpleInvoker.invoke_process windowed_value, self.process_method(windowed_value.value)) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/transforms/core.py";,> line -1, in <lambda> File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line 1349, in first assert_that( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line 1350, in second pcoll | 'PackableMax' >> beam.CombineGlobally(max_with_counter), File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner_test.py";,> line -1, in third ValueError: This error is expected and does not indicate a test failure. [while running 'Map(first)'] warnings.warn(pytest.PytestUnhandledThreadExceptionWarning(msg)) apache_beam/runners/portability/portable_runner_test.py::PortableRunnerTestWithLocalDocker::test_sdf_with_check_done_failed <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/_pytest/threadexception.py>:73: PytestUnhandledThreadExceptionWarning: Exception in thread Thread-2490 (_run_job) Traceback (most recent call last): File "/usr/lib/python3.10/threading.py", line 1009, in _bootstrap_inner self.run() File "/usr/lib/python3.10/threading.py", line 946, in run self._target(*self._args, **self._kwargs) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/local_job_service.py";,> line 296, in _run_job self.result = self._invoke_runner() File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/local_job_service.py";,> line 319, in _invoke_runner provision_info=self._provision_info).run_via_runner_api( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 224, in run_via_runner_api return self.run_stages(stage_context, stages) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 455, in run_stages bundle_results = self._execute_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 783, in _execute_bundle self._run_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1012, in _run_bundle result, splits = bundle_manager.process_bundle( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/fn_runner.py";,> line 1348, in process_bundle result_future = self._worker_handler.control_conn.push(process_bundle_req) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/portability/fn_api_runner/worker_handlers.py";,> line 379, in push response = self.worker.do_instruction(request) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 629, in do_instruction return getattr(self, request_type)( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 667, in process_bundle bundle_processor.process_bundle(instruction_id)) File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1062, in process_bundle input_op_by_transform_id[element.transform_id].process_encoded( File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 232, in process_encoded self.output(decoded_value) File "apache_beam/runners/worker/operations.py", line 526, in apache_beam.runners.worker.operations.Operation.output def output(self, windowed_value, output_index=0): File "apache_beam/runners/worker/operations.py", line 528, in apache_beam.runners.worker.operations.Operation.output _cast_to_receiver(self.receivers[output_index]).receive(windowed_value) File "apache_beam/runners/worker/operations.py", line 237, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive def receive(self, windowed_value): File "apache_beam/runners/worker/operations.py", line 240, in apache_beam.runners.worker.operations.SingletonElementConsumerSet.receive self.consumer.process(windowed_value) File "apache_beam/runners/worker/operations.py", line 1021, in apache_beam.runners.worker.operations.SdfProcessSizedElements.process with self.scoped_process_state: File "apache_beam/runners/worker/operations.py", line 1030, in apache_beam.runners.worker.operations.SdfProcessSizedElements.process delayed_applications = self.dofn_runner.process_with_sized_restriction( File "apache_beam/runners/common.py", line 1433, in apache_beam.runners.common.DoFnRunner.process_with_sized_restriction return self.do_fn_invoker.invoke_process( File "apache_beam/runners/common.py", line 818, in apache_beam.runners.common.PerWindowInvoker.invoke_process residual = self._invoke_process_per_window( File "apache_beam/runners/common.py", line 989, in apache_beam.runners.common.PerWindowInvoker._invoke_process_per_window self.threadsafe_restriction_tracker.check_done() File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/sdf_utils.py";,> line 111, in check_done return self._restriction_tracker.check_done() File "<https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/io/restriction_trackers.py";,> line 93, in check_done raise ValueError( ValueError: OffsetRestrictionTracker is not done since work in range [0, 6) has not been claimed. warnings.warn(pytest.PytestUnhandledThreadExceptionWarning(msg)) apache_beam/runners/worker/worker_status_test.py::FnApiWorkerStatusHandlerTest::test_generate_error apache_beam/runners/worker/worker_status_test.py::FnApiWorkerStatusHandlerTest::test_send_status_response apache_beam/runners/worker/worker_status_test.py::FnApiWorkerStatusHandlerTest::test_send_status_response <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/apache_beam/runners/worker/worker_status_test.py>:48: DeprecationWarning: notifyAll() is deprecated, use notify_all() instead self.finished.notifyAll() -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html - generated xml file: <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/pytest_py310-cython.xml> - ========== 1181 passed, 769 skipped, 41 warnings in 225.08s (0:03:45) ========== ============================= test session starts ============================== platform linux -- Python 3.10.2, pytest-7.3.1, pluggy-1.0.0 cachedir: target/.tox-py310-cython/py310-cython/.pytest_cache rootdir: <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python> configfile: pytest.ini plugins: xdist-3.2.1, hypothesis-6.75.2, timeout-2.1.0, requests-mock-1.10.0 timeout: 600.0s timeout method: signal timeout func_only: False collected 1952 items / 1949 deselected / 1 skipped / 3 selected apache_beam/runners/dataflow/dataflow_exercise_streaming_metrics_pipeline_test.py s [ 33%] [ 33%] apache_beam/runners/portability/stager_test.py .. [100%] =============================== warnings summary =============================== target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/hdfs/config.py:15 <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/hdfs/config.py>:15: DeprecationWarning: the imp module is deprecated in favour of importlib and slated for removal in Python 3.12; see the module's documentation for alternative uses from imp import load_source target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/pkg_resources/__init__.py:121 <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/target/.tox-py310-cython/py310-cython/lib/python3.10/site-packages/pkg_resources/__init__.py>:121: DeprecationWarning: pkg_resources is deprecated as an API warnings.warn("pkg_resources is deprecated as an API", DeprecationWarning) -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html - generated xml file: <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/pytest_py310-cython_no_xdist.xml> - ========== 2 passed, 2 skipped, 1949 deselected, 2 warnings in 1.08s =========== [1mpy310-cython run-test-post: commands[0] | bash <https://ci-beam.apache.org/job/beam_PreCommit_Python_Runners_Cron/ws/src/sdks/python/test-suites/tox/py310/build/srcs/sdks/python/scripts/run_tox_cleanup.sh> [0m___________________________________ summary ____________________________________ [32m py310-cython: commands succeeded [0m[32m congratulations :) [0m FAILURE: Build failed with an exception. * What went wrong: Execution failed for task ':sdks:python:test-suites:tox:py310:testPy310Cloud'. > 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. * Get more help at https://help.gradle.org BUILD FAILED in 25m 57s 26 actionable tasks: 20 executed, 4 from cache, 2 up-to-date Build scan background action failed. java.lang.IllegalArgumentException: com.gradle.enterprise.gradleplugin.internal.extension.a is not an interface at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:590) at java.lang.reflect.Proxy$ProxyClassFactory.apply(Proxy.java:557) at java.lang.reflect.WeakCache$Factory.get(WeakCache.java:230) at java.lang.reflect.WeakCache.get(WeakCache.java:127) at java.lang.reflect.Proxy.getProxyClass0(Proxy.java:419) at java.lang.reflect.Proxy.newProxyInstance(Proxy.java:719) at com.gradle.ProxyFactory$ProxyingInvocationHandler.createLocalProxy(ProxyFactory.java:66) at com.gradle.ProxyFactory$ProxyingInvocationHandler.lambda$adaptActionArg$1(ProxyFactory.java:61) at com.gradle.enterprise.gradleplugin.internal.extension.b$3.run(SourceFile:100) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:750) Publishing build scan... https://ge.apache.org/s/zsealxsyja6qc 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]
