See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1008/display/redirect?page=changes>
Changes: [Alexey Romanenko] [TPC-DS] Use "nonpartitioned" input for Jenkins jobs [noreply] Update scopes to match the existing set and update test to clear ------------------------------------------ [...truncated 19.77 MB...] 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 597, in do_instruction getattr(request, request_type), request.instruction_id) 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 1004, in process_bundle element.data) 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 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 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 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 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 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 "pytest: reading from stdin while output is captured! Consider using `-s`." OSError: pytest: reading from stdin while output is captured! Consider using `-s`. [while running 'read table/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSize0'] ERROR apache_beam.runners.worker.data_plane:data_plane.py:661 Failed to read inputs in the data plane. 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/data_plane.py";,> line 654, in _read_inputs for elements in elements_iterator: File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,> line 426, in __next__ return self._next() File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_channel.py";,> line 809, in _next raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.CANCELLED details = "Multiplexer hanging up" debug_error_string = "UNKNOWN:Error received from peer ipv4:127.0.0.1:38039 {created_time:"2022-10-18T09:47:41.874772347+00:00", grpc_status:1, grpc_message:"Multiplexer hanging up"}" > ERROR root:portable_runner.py:577 java.lang.RuntimeException: Error received from SDK harness for instruction 48: 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 "pytest: reading from stdin while output is captured! Consider using `-s`." 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 597, in do_instruction getattr(request, request_type), request.instruction_id) 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 1004, in process_bundle element.data) 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 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 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 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 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 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 "pytest: reading from stdin while output is captured! Consider using `-s`." OSError: pytest: reading from stdin while output is captured! Consider using `-s`. [while running 'read table/Read/SDFBoundedSourceReader/ParDo(SDFBoundedSourceDoFn)/SplitAndSize0'] FAILED [ 95%] apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays ERROR [ 95%] apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics -------------------------------- live log call --------------------------------- INFO root:pipeline.py:188 Missing pipeline option (runner). Executing pipeline using the default runner: DirectRunner. INFO root:transforms.py:182 Computing dataframe stage <ComputeStage(PTransform) label=[[ComputedExpression[set_column_DataFrame_140229164748176], ComputedExpression[set_index_DataFrame_140229546772496], ComputedExpression[pre_combine_sum_DataFrame_140229595290320]]:140229979138832]> for Stage[inputs={PlaceholderExpression[placeholder_DataFrame_140229545666384]}, partitioning=Arbitrary, ops=[ComputedExpression[set_column_DataFrame_140229164748176], ComputedExpression[set_index_DataFrame_140229546772496], ComputedExpression[pre_combine_sum_DataFrame_140229595290320]], outputs={PlaceholderExpression[placeholder_DataFrame_140229545666384], ComputedExpression[pre_combine_sum_DataFrame_140229595290320]}] INFO root:transforms.py:182 Computing dataframe stage <ComputeStage(PTransform) label=[[ComputedExpression[post_combine_sum_DataFrame_140231738091728]]:140229979139472]> for Stage[inputs={ComputedExpression[pre_combine_sum_DataFrame_140229595290320]}, partitioning=Index, ops=[ComputedExpression[post_combine_sum_DataFrame_140231738091728]], outputs={ComputedExpression[post_combine_sum_DataFrame_140231738091728]}] INFO apache_beam.io.fileio:fileio.py:595 Added temporary directory /tmp/.temp37f2e851-3451-46de-a62e-10d28c055594 INFO root:environments.py:376 Default Python SDK image for environment is apache/beam_python3.7_sdk:2.43.0.dev > Task :sdks:python:test-suites:portable:py39:flinkExamples PASSED [100%] ==================================== ERRORS ==================================== _ ERROR at teardown of UserScoreIT.test_userscore_output_checksum_on_small_input _ 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]
