See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1016/display/redirect?page=changes>
Changes: [noreply] Speed up check on website links (#23737) ------------------------------------------ [...truncated 16.04 MB...] File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1419, in process self._reraise_augmented(exn) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1491, in _reraise_augmented raise exn File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1581, in handle_process_outputs self._write_value_to_tag(tag, windowed_value, watermark_estimator) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1694, in _write_value_to_tag self.main_receivers.receive(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 240, in receive self.consumer.process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 908, in process delayed_applications = self.dofn_runner.process(o) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1419, in process self._reraise_augmented(exn) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1507, in _reraise_augmented raise new_exn.with_traceback(tb) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1571, in handle_process_outputs for result in results: File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1457, in process raise ValueError('Expected size >= 0 but received %s.' % size) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/transforms/core.py";,> line 331, in split_and_size for part in self.split(element, restriction): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/iobase.py";,> line 1641, in split estimated_size = restriction.source().estimate_size() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py";,> line 697, in estimate_size bq = bigquery_tools.BigQueryWrapper() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_tools.py";,> line 333, in __init__ self.client = client or bigquery.BigqueryV2( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py";,> line 51, in __init__ super().__init__( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 261, in __init__ self._SetCredentials(**credentials_args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 309, in _SetCredentials self._credentials = credentials_lib.GetCredentials(**args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 153, in GetCredentials credentials = CredentialsFromFile(credentials_filename, client_info, File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 560, in CredentialsFromFile credentials = tools.run_flow(flow, credential_store, flags) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/_helpers.py";,> line 133, in positional_wrapper return wrapped(*args, **kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/tools.py";,> line 240, in run_flow code = input('Enter verification code: ').strip() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/_pytest/capture.py";,> line 192, in read raise OSError( OSError: pytest: reading from stdin while output is captured! Consider using `-s`. [while running 'read corpus/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSize0'] ERROR apache_beam.runners.worker.sdk_worker:sdk_worker.py:291 Error processing instruction 128. Original traceback is Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1571, in handle_process_outputs for result in results: File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1457, in process raise ValueError('Expected size >= 0 but received %s.' % size) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/transforms/core.py";,> line 331, in split_and_size for part in self.split(element, restriction): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/iobase.py";,> line 1641, in split estimated_size = restriction.source().estimate_size() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py";,> line 697, in estimate_size bq = bigquery_tools.BigQueryWrapper() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_tools.py";,> line 333, in __init__ self.client = client or bigquery.BigqueryV2( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py";,> line 51, in __init__ super().__init__( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 261, in __init__ self._SetCredentials(**credentials_args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 309, in _SetCredentials self._credentials = credentials_lib.GetCredentials(**args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 153, in GetCredentials credentials = CredentialsFromFile(credentials_filename, client_info, File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 560, in CredentialsFromFile credentials = tools.run_flow(flow, credential_store, flags) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/_helpers.py";,> line 133, in positional_wrapper return wrapped(*args, **kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/tools.py";,> line 240, in run_flow code = input('Enter verification code: ').strip() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/_pytest/capture.py";,> line 192, in read raise OSError( OSError: pytest: reading from stdin while output is captured! Consider using `-s`. During handling of the above exception, another exception occurred: Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 287, in _execute response = task() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 360, in <lambda> lambda: self.create_worker().do_instruction(request), request) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 596, in do_instruction return getattr(self, request_type)( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 634, in process_bundle bundle_processor.process_bundle(instruction_id)) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1003, in process_bundle input_op_by_transform_id[element.transform_id].process_encoded( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 227, in process_encoded self.output(decoded_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 528, in output _cast_to_receiver(self.receivers[output_index]).receive(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 240, in receive self.consumer.process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 908, in process delayed_applications = self.dofn_runner.process(o) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1419, in process self._reraise_augmented(exn) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1491, in _reraise_augmented raise exn File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1581, in handle_process_outputs self._write_value_to_tag(tag, windowed_value, watermark_estimator) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1694, in _write_value_to_tag self.main_receivers.receive(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 240, in receive self.consumer.process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 908, in process delayed_applications = self.dofn_runner.process(o) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1419, in process self._reraise_augmented(exn) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1491, in _reraise_augmented raise exn File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1581, in handle_process_outputs self._write_value_to_tag(tag, windowed_value, watermark_estimator) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1694, in _write_value_to_tag self.main_receivers.receive(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 240, in receive self.consumer.process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/operations.py";,> line 908, in process delayed_applications = self.dofn_runner.process(o) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1419, in process self._reraise_augmented(exn) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1507, in _reraise_augmented raise new_exn.with_traceback(tb) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 623, in invoke_process self.output_handler.handle_process_outputs( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1571, in handle_process_outputs for result in results: File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1457, in process raise ValueError('Expected size >= 0 but received %s.' % size) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/transforms/core.py";,> line 331, in split_and_size for part in self.split(element, restriction): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/iobase.py";,> line 1641, in split estimated_size = restriction.source().estimate_size() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py";,> line 697, in estimate_size bq = bigquery_tools.BigQueryWrapper() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_tools.py";,> line 333, in __init__ self.client = client or bigquery.BigqueryV2( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py";,> line 51, in __init__ super().__init__( File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 261, in __init__ self._SetCredentials(**credentials_args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/base_api.py";,> line 309, in _SetCredentials self._credentials = credentials_lib.GetCredentials(**args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 153, in GetCredentials credentials = CredentialsFromFile(credentials_filename, client_info, File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/apitools/base/py/credentials_lib.py";,> line 560, in CredentialsFromFile credentials = tools.run_flow(flow, credential_store, flags) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/_helpers.py";,> line 133, in positional_wrapper return wrapped(*args, **kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/oauth2client/tools.py";,> line 240, in run_flow code = input('Enter verification code: ').strip() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/-1720702907/lib/python3.10/site-packages/_pytest/capture.py";,> line 192, in read raise OSError( OSError: pytest: reading from stdin while output is captured! Consider using `-s`. [while running 'read_words/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSize0'] FAILED [ 56%] apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it ERROR [ 56%] apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it -------------------------------- live log call --------------------------------- INFO apache_beam.runners.worker.worker_pool_main:worker_pool_main.py:93 Listening for workers at localhost:41123 INFO root:environments.py:376 Default Python SDK image for environment is apache/beam_python3.10_sdk:2.43.0.dev INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 ==================== <function pack_combiners at 0x7fbb6c4ed240> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 ==================== <function lift_combiners at 0x7fbb6c4ed2d0> ==================== INFO apache_beam.runners.portability.fn_api_runner.translations:translations.py:714 ==================== <function sort_stages at 0x7fbb6c4eda20> ==================== INFO apache_beam.utils.subprocess_server:subprocess_server.py:116 Starting service with ['java' '-jar' '<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/runners/flink/1.15/job-server/build/libs/beam-runners-flink-1.15-job-server-2.43.0-SNAPSHOT.jar'> '--flink-master' '[auto]' '--artifacts-dir' '/tmp/beam-tempym4q0k00/artifacts8nul3n79' '--job-port' '33819' '--artifact-port' '0' '--expansion-port' '0'] INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:11 AM software.amazon.awssdk.regions.internal.util.EC2MetadataUtils getItems INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 WARNING: Unable to retrieve the requested metadata. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:12 AM org.apache.beam.runners.jobsubmission.JobServerDriver createArtifactStagingService INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: ArtifactStagingService started on localhost:34175 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:12 AM org.apache.beam.runners.jobsubmission.JobServerDriver createExpansionService INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Java ExpansionService started on localhost:37373 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:12 AM org.apache.beam.runners.jobsubmission.JobServerDriver createJobServer INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: JobService started on localhost:33819 INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:12 AM org.apache.beam.runners.jobsubmission.JobServerDriver run INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job server now running, terminate with Ctrl+C WARNING root:subprocess_server.py:95 Waiting for grpc channel to be ready at localhost:33819. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:14 AM org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Staging artifacts for job_84ad6793-3f73-4ca2-a28c-ffd1079ad53f. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:14 AM org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 resolveNextEnvironment INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Resolving artifacts for job_84ad6793-3f73-4ca2-a28c-ffd1079ad53f.ref_Environment_default_environment_1. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:14 AM org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 onNext INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Getting 0 artifacts for job_84ad6793-3f73-4ca2-a28c-ffd1079ad53f.null. INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 20, 2022 9:43:14 AM org.apache.beam.runners.fnexecution.artifact.ArtifactStagingService$2 finishStaging INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Artifacts fully staged for job_84ad6793-3f73-4ca2-a28c-ffd1079ad53f. > Task :sdks:python:test-suites:portable:py37:flinkExamples ERROR apache_beam.runners.worker.sdk_worker:sdk_worker.py:294 Error processing instruction 20. Original traceback is Traceback (most recent call last): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1417, in process return self.do_fn_invoker.invoke_process(windowed_value) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 624, in invoke_process windowed_value, self.process_method(windowed_value.value)) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/common.py";,> line 1571, in handle_process_outputs for result in results: File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/bundle_processor.py";,> line 1455, in process element, restriction): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/transforms/core.py";,> line 331, in split_and_size for part in self.split(element, restriction): File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/iobase.py";,> line 1641, in split estimated_size = restriction.source().estimate_size() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py";,> line 697, in estimate_size bq = bigquery_tools.BigQueryWrapper() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_tools.py";,> line 338, in __init__ "user-agent": "apache-beam-%s" % apache_beam.__version__ File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/internal/clients/bigquery/bigquery_v2_client.py";,> line 58, in __init__ response_encoding=response_encoding) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/apitools/base/py/base_api.py";,> line 261, in __init__ self._SetCredentials(**credentials_args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/apitools/base/py/base_api.py";,> line 309, in _SetCredentials self._credentials = credentials_lib.GetCredentials(**args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/apitools/base/py/credentials_lib.py";,> line 154, in GetCredentials oauth2client_args=oauth2client_args) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/apitools/base/py/credentials_lib.py";,> line 560, in CredentialsFromFile credentials = tools.run_flow(flow, credential_store, flags) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/oauth2client/_helpers.py";,> line 133, in positional_wrapper return wrapped(*args, **kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/oauth2client/tools.py";,> line 240, in run_flow code = input('Enter verification code: ').strip() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/_pytest/capture.py";,> line 193, in read java.lang.OutOfMemoryError: GC overhead limit exceeded 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]
