See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/756/display/redirect>
Changes: ------------------------------------------ [...truncated 108.79 MB...] File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/sdk_worker.py";,> line 203, in default_factory process_bundle_descriptor_id=id)) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_interceptor.py";,> line 221, in __call__ compression=compression) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_interceptor.py";,> line 257, in _with_call return call.result(), call 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 343, in result raise self File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/grpc/_interceptor.py";,> line 247, in continuation compression=new_compression) 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 957, in with_call return _end_unary_response_blocking(state, call, True, None) 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 849, in _end_unary_response_blocking raise _InactiveRpcError(state) grpc._channel._InactiveRpcError: <_InactiveRpcError of RPC that terminated with: status = StatusCode.UNAVAILABLE details = "failed to connect to all addresses" debug_error_string = "{"created":"@1660643017.354926809","description":"Failed to pick subchannel","file":"src/core/ext/filters/client_channel/client_channel.cc","file_line":3260,"referenced_errors":[{"created":"@1660643017.354925426","description":"failed to connect to all addresses","file":"src/core/lib/transport/error_utils.cc","file_line":167,"grpc_status":14}]}" > INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (7762fa8b1da4d6c2176217228119bac7) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (89a530e7ed88f1c1f1ba97a13c310050) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (7b190ecb5c7a5e303a29072f06ef8aed) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16) (attempt #0) with attempt id 7762fa8b1da4d6c2176217228119bac7 and vertex id 09a1a6aa9a0e65748c5e51e4eff0ada5_1 to b714bbc1-89ad-4df0-8e6d-0e4c6b007b26 @ localhost (dataPort=-1) with allocation id fddeaa15e050da35f14d703593ed3721 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (89a530e7ed88f1c1f1ba97a13c310050) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Received task CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (14655d29438ccf1e33355105a61c5584), deploy into slot with allocation id fddeaa15e050da35f14d703593ed3721. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator ERROR root:portable_runner.py:577 java.io.IOException: Insufficient number of network buffers: required 17, but only 3 available. The total number of network buffers is currently set to 2048 of 32768 bytes each. You can increase this number by setting the configuration keys 'taskmanager.memory.network.fraction', 'taskmanager.memory.network.min', and 'taskmanager.memory.network.max'. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING: The operator name MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) exceeded the 80 characters length limit and was truncated. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)#0 (7b190ecb5c7a5e303a29072f06ef8aed) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.runners.portability.portable_runner:portable_runner.py:583 Job state changed to FAILED INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (1579d795e0def40d0c2e6de4136b6b10) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.metrics.groups.TaskMetricGroup getOrAddOperator INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING: The operator name MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) exceeded the 80 characters length limit and was truncated. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16) (attempt #0) with attempt id 1579d795e0def40d0c2e6de4136b6b10 and vertex id 09a1a6aa9a0e65748c5e51e4eff0ada5_2 to b714bbc1-89ad-4df0-8e6d-0e4c6b007b26 @ localhost (dataPort=-1) with allocation id 1993dc2ac62e401bb018405450fb01fa INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 1993dc2ac62e401bb018405450fb01fa. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (14655d29438ccf1e33355105a61c5584) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Loading JAR files for task CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (14655d29438ccf1e33355105a61c5584) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (efdc9c56763dd28e09ca9fa82e1acdc6) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16) (attempt #0) with attempt id efdc9c56763dd28e09ca9fa82e1acdc6 and vertex id 09a1a6aa9a0e65748c5e51e4eff0ada5_3 to b714bbc1-89ad-4df0-8e6d-0e4c6b007b26 @ localhost (dataPort=-1) with allocation id 2e3247e3947aab642291b17495b9253c INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (14655d29438ccf1e33355105a61c5584) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (5529d5211f853c0d2f0d0a34aee4fc9c) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (14655d29438ccf1e33355105a61c5584) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Received task CHAIN MapPartition (MapPartition at [2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)#0 (7f0f0d251082e7d6a9c19b2d42dc6440), deploy into slot with allocation id 1993dc2ac62e401bb018405450fb01fa. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:34 AM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]attach corpus) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16) (attempt #0) with attempt id 5529d5211f853c0d2f0d0a34aee4fc9c and vertex id 09a1a6aa9a0e65748c5e51e4eff0ada5_4 to b714bbc1-89ad-4df0-8e6d-0e4c6b007b26 @ localhost (dataPort=-1) with allocation id f04d036221badee7de3f0bc9d77bcc60 ---------------------------- Captured log teardown ----------------------------- INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:36 AM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup addMetric INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING: Name collision: Group already contains a Metric with the name 'numBytesInLocalPerSecond'. Metric will not be reported.[, taskmanager, b714bbc1-89ad-4df0-8e6d-0e4c6b007b26, BeamApp-jenkins-0816094323-2e550a6c, MapPartition (MapPartition at [1]read corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 10, Shuffle, Netty, Input] INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 16, 2022 9:43:36 AM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup addMetric INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING: Name collision: Group already contains a Metric with the name 'numBytesInLocal'. Metric will not be reported.[, taskmanager, b714bbc1-89ad-4df0-8e6d-0e4c6b007b26, BeamApp-jenkins-0816094323-2e550a6c, MapPartition (MapPartition at [1]read corpus/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 10] =============================== warnings summary =============================== ../../build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py:15 <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/build/gradleenv/2022703441/lib/python3.7/site-packages/hdfs/config.py>:15: DeprecationWarning: the imp module is deprecated in favour of importlib; see the module's documentation for alternative uses from imp import load_source apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:63: PendingDeprecationWarning: Client.dataset is deprecated and will be removed in a future version. Use a string like 'my_project.my_dataset' or a cloud.google.bigquery.DatasetReference object, instead. dataset_ref = client.dataset(unique_dataset_name, project=project) apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2285: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported is_streaming_pipeline = p.options.view_as(StandardOptions).streaming apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2291: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported experiments = p.options.view_as(DebugOptions).experiments or [] apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1129: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported temp_location = p.options.view_as(GoogleCloudOptions).temp_location apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_output_checksum_on_small_input apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery_file_loads.py>:1131: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported p.options.view_as(GoogleCloudOptions).job_name or 'AUTOMATIC_JOB_NAME') apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2774: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported temp_location = pcoll.pipeline.options.view_as( apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2776: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported job_name = pcoll.pipeline.options.view_as(GoogleCloudOptions).job_name apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2807: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported | _PassThroughThenCleanup(files_to_remove_pcoll)) apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/bigquery.py>:2281: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported self.table_reference.projectId = pcoll.pipeline.options.view_as( apache_beam/examples/cookbook/bigquery_tornadoes_it_test.py::BigqueryTornadoesIT::test_bigquery_tornadoes_it apache_beam/examples/cookbook/filters_test.py::FiltersTest::test_filters_output_bigquery_matcher <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/gcp/tests/utils.py>:100: PendingDeprecationWarning: Client.dataset is deprecated and will be removed in a future version. Use a string like 'my_project.my_dataset' or a cloud.google.bigquery.DatasetReference object, instead. table_ref = client.dataset(dataset_id).table(table_id) apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays Exception in thread read_grpc_client_inputs: Traceback (most recent call last): File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner self.run() File "/usr/lib/python3.7/threading.py", line 870, in run self._target(*self._args, **self._kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,> line 671, in <lambda> target=lambda: self._read_inputs(elements_iterator), 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: <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/examples/dataframe/flight_delays.py>:47: FutureWarning: Dropping of nuisance columns in DataFrame reductions (with 'numeric_only=None') is deprecated; in a future version this will raise TypeError. Select only valid columns before calling the reduction. return airline_df[at_top_airports].mean() apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/dataframe/io.py>:632: FutureWarning: WriteToFiles is experimental. sink=lambda _: _WriteToPandasFileSink( 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 826, in _next raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.CANCELLED details = "Multiplexer hanging up" debug_error_string = "{"created":"@1660643050.881574576","description":"Error received from peer ipv6:[::1]:43597","file":"src/core/lib/surface/call.cc","file_line":966,"grpc_message":"Multiplexer hanging up","grpc_status":1}" > Exception in thread read_grpc_client_inputs: Traceback (most recent call last): File "/usr/lib/python3.7/threading.py", line 926, in _bootstrap_inner self.run() File "/usr/lib/python3.7/threading.py", line 870, in run self._target(*self._args, **self._kwargs) File "<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/runners/worker/data_plane.py";,> line 671, in <lambda> target=lambda: self._read_inputs(elements_iterator), 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 826, in _next apache_beam/examples/dataframe/flight_delays_it_test.py::FlightDelaysTest::test_flight_delays apache_beam/examples/dataframe/wordcount_test.py::WordCountTest::test_basics <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/apache_beam/io/fileio.py>:581: BeamDeprecationWarning: options is deprecated since First stable release. References to <pipeline>.options will not be supported p.options.view_as(GoogleCloudOptions).temp_location or -- Docs: https://docs.pytest.org/en/stable/how-to/capture-warnings.html - generated xml file: <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/pytest_postCommitExamples-flink-py37.xml> - =========================== short test summary info ============================ FAILED apache_beam/examples/cookbook/bigquery_side_input_it_test.py::BigQuerySideInputIT::test_bigquery_side_input_it = 1 failed, 21 passed, 3 skipped, 6527 deselected, 39 warnings in 481.73s (0:08:01) = raise self grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that terminated with: status = StatusCode.CANCELLED details = "Multiplexer hanging up" debug_error_string = "{"created":"@1660643113.261850287","description":"Error received from peer ipv6:[::1]:35999","file":"src/core/lib/surface/call.cc","file_line":966,"grpc_message":"Multiplexer hanging up","grpc_status":1}" > > Task :sdks:python:test-suites:portable:py37:flinkExamples FAILED FAILURE: Build completed with 2 failures. 1: Task failed with an exception. ----------- * Where: Script '<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 240 * What went wrong: Execution failed for task ':sdks:python:test-suites:portable:py39:flinkExamples'. > 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. ============================================================================== 2: Task failed with an exception. ----------- * Where: Script '<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'> line: 240 * What went wrong: Execution failed for task ':sdks:python:test-suites:portable:py37:flinkExamples'. > 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 BUILD FAILED in 9m 41s 133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/swl27sh4v6acq 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]
