See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/818/display/redirect?page=changes>
Changes: [Brian Hulette] Extract utilities in dataframe.schemas [Brian Hulette] Add pandas_type_compatibility with pandas BatchConverter implementations [Brian Hulette] Use Batched DoFns at DataFrame API boundaries [Brian Hulette] Move dtype conversion to pandas_type_compatibility [Brian Hulette] Always register pandas BatchConverters [Brian Hulette] Fix interactive runner tests [Brian Hulette] Use pandas_type_compatibility BatchConverters for dataframe.schemas [Brian Hulette] Skip test cases broken in pandas 1.1.x [Brian Hulette] Address review comments [Brian Hulette] yapf, typo in test [noreply] Add ability to remove/clear map and set state (#22938) [noreply] Fix gpu to cpu conversion with warning logs (#22795) [noreply] Add Go stateful DoFns to CHANGES.md and fix linting violations (#22958) [noreply] 22805: Upgrade Jackson version from 2.13.0 to 2.13.3 (#22806) [noreply] Run cred rotation every month (#22977) ------------------------------------------ [...truncated 108.84 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (9/16)#0 (ba770054da434f3108a4d87a27f7a7e8) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (9/16)#0 (ba770054da434f3108a4d87a27f7a7e8). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Received task FlatMap (FlatMap at ExtractOutput[1]) (12/16)#0 (30da42238e13712ea55270c6b8edecd8), deploy into slot with allocation id 0d09df262edcf050cf493d4bf0621e44. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (11/16) (f7b8ff4510d0322a9ba816e9c96c6a19) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (11/16) (f7b8ff4510d0322a9ba816e9c96c6a19) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (12/16) (830fe3f7f19b7d6b8406b1e7498ca402) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService getProcessBundleDescriptor INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: getProcessBundleDescriptor request with id 2-28 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (12/16) (830fe3f7f19b7d6b8406b1e7498ca402) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (13/16) (195ffbf9c271cb4d371f775641ac68b3) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (13/16) (195ffbf9c271cb4d371f775641ac68b3) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (14/16) (ae68cfa8d793cd1ad7ee9e90d11ce2a6) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (14/16) (ae68cfa8d793cd1ad7ee9e90d11ce2a6) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (15/16) (dd3c062fd2fc38e1b76ad1914ee2d0eb) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (15/16) (dd3c062fd2fc38e1b76ad1914ee2d0eb) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (16/16) (f6f6a1c2dc138a6804598cd8137a333c) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (16/16) (f6f6a1c2dc138a6804598cd8137a333c) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (2/16) (0eb5077985c0e2dac3f185f41ad06f6b) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (12/16)#0 (830fe3f7f19b7d6b8406b1e7498ca402) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (11/16)#0 (f7b8ff4510d0322a9ba816e9c96c6a19) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (2/16) (0eb5077985c0e2dac3f185f41ad06f6b) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot afd0d774b21a6e77870317be8f16d63d. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (11/16)#0 (f7b8ff4510d0322a9ba816e9c96c6a19). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Received task FlatMap (FlatMap at ExtractOutput[1]) (13/16)#0 (f6d8fb27fc413cf37fbc62aba8b63492), deploy into slot with allocation id afd0d774b21a6e77870317be8f16d63d. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (13/16)#0 (195ffbf9c271cb4d371f775641ac68b3) switched from RUNNING to FINISHED. ERROR root:portable_runner.py:577 java.io.IOException: Insufficient number of network buffers: required 17, but only 10 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 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (12/16)#0 (30da42238e13712ea55270c6b8edecd8) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (13/16)#0 (195ffbf9c271cb4d371f775641ac68b3). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (13/16)#0 (f6d8fb27fc413cf37fbc62aba8b63492) switched from CREATED to DEPLOYING. 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 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (10/16)#0 (a5e224426954e34cb02ff8055534523f) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[1]) (12/16)#0 (30da42238e13712ea55270c6b8edecd8) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (10/16)#0 (a5e224426954e34cb02ff8055534523f). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (12/16)#0 (830fe3f7f19b7d6b8406b1e7498ca402). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 922fa126a44d73833807f41e2f184d13. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (1/16) (b21b3c289d2a5f60bf2f19915b20234f) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[1]) (13/16)#0 (f6d8fb27fc413cf37fbc62aba8b63492) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (1/16) (b21b3c289d2a5f60bf2f19915b20234f) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (12/16)#0 (30da42238e13712ea55270c6b8edecd8) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (13/16)#0 (f6d8fb27fc413cf37fbc62aba8b63492) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (3/16) (b7a3972a1614fbfad9a83fee9ee9ca3e) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (13/16)#0 (f6d8fb27fc413cf37fbc62aba8b63492) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (12/16)#0 (30da42238e13712ea55270c6b8edecd8) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (3/16) (b7a3972a1614fbfad9a83fee9ee9ca3e) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Received task FlatMap (FlatMap at ExtractOutput[1]) (14/16)#0 (3e28a3aa5d72529069c0070e87a6ec8e), deploy into slot with allocation id 922fa126a44d73833807f41e2f184d13. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (5/16) (0de9c7fa80898710b426a26a04b6006b) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (14/16)#0 (ae68cfa8d793cd1ad7ee9e90d11ce2a6) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (5/16) (0de9c7fa80898710b426a26a04b6006b) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (14/16)#0 (3e28a3aa5d72529069c0070e87a6ec8e) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Freeing task resources for DataSource (Impulse) (14/16)#0 (ae68cfa8d793cd1ad7ee9e90d11ce2a6). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskmanager.Task doRun INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Loading JAR files for task FlatMap (FlatMap at ExtractOutput[1]) (14/16)#0 (3e28a3aa5d72529069c0070e87a6ec8e) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 13ac9bf7a787668e7698ed62ace8140e. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (4/16) (00ebb54559d833e9f3583601c644a3ec) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (4/16) (00ebb54559d833e9f3583601c644a3ec) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:15 PM org.apache.flink.runtime.executiongraph.Execution transitionState --------------------------- Captured stdout teardown --------------------------- FAILED [ 56%] ---------------------------- Captured log teardown ----------------------------- INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:17 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot afd0d774b21a6e77870317be8f16d63d. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 31, 2022 9:49:17 PM org.apache.flink.runtime.taskmanager.Task transitionState =============================== 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 <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>:637: FutureWarning: WriteToFiles is experimental. sink=lambda _: _WriteToPandasFileSink( 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>:590: 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, 6624 deselected, 39 warnings in 554.12s (0:09:14) = > 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 15m 47s 133 actionable tasks: 99 executed, 32 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/n5hya4zefiwnq 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]
