See <https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/753/display/redirect?page=changes>
Changes: [noreply] Attempt to fix SpannerIO test flakes (#22688) ------------------------------------------ [...truncated 108.84 MB...] INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (d11a310690732a01fdb2da389ed37bb7) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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]) (15/16)#0 (130635e39c430cda864d338ddd51401c) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot b2cf705302de7282d0d5801bd0f18a26. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16) (attempt #0) with attempt id d11a310690732a01fdb2da389ed37bb7 and vertex id fd1593b680552266088a4484f9b6d199_9 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id 7caca5fa7f571c480df8908e96f74cde INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (16/16)#0 (763edc918413953cefe531416f1dce0a) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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]) (16/16)#0 (763edc918413953cefe531416f1dce0a) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (15/16)#0 (130635e39c430cda864d338ddd51401c) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (4c7e74983ec4c27221394158c8d32e9f) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (15/16)#0 (130635e39c430cda864d338ddd51401c) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16) (attempt #0) with attempt id 4c7e74983ec4c27221394158c8d32e9f and vertex id fd1593b680552266088a4484f9b6d199_10 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id 1fc6d65511e300fda2795e91f81686d8 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (16/16)#0 (763edc918413953cefe531416f1dce0a) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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[0]) (1/16)#0 (d6da4aa057d377a33250b312b87503e1), deploy into slot with allocation id b2cf705302de7282d0d5801bd0f18a26. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (d89bc5f5121ed53cee30b3341b17a7e5) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[1]) (16/16)#0 (763edc918413953cefe531416f1dce0a) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 1fc6d65511e300fda2795e91f81686d8. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16) (attempt #0) with attempt id d89bc5f5121ed53cee30b3341b17a7e5 and vertex id fd1593b680552266088a4484f9b6d199_11 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id a1afab6cd94ee4c59a347eba4896b4d8 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (9e630d9514a2cf80950cc6d681b371a2) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16) (attempt #0) with attempt id 9e630d9514a2cf80950cc6d681b371a2 and vertex id fd1593b680552266088a4484f9b6d199_12 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id c3035fdbaebc0fe49d3a41b4b2703909 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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]) (11/16)#0 (0cad8aa28c69069710e8bd16bdd701ce), deploy into slot with allocation id 1fc6d65511e300fda2795e91f81686d8. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (32ff31b442c5c927f76bb41069cdf491) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16) (attempt #0) with attempt id 32ff31b442c5c927f76bb41069cdf491 and vertex id fd1593b680552266088a4484f9b6d199_13 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id 4310a76df66718cdcc6204b105a9c2af INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (d6da4aa057d377a33250b312b87503e1) switched from CREATED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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[0]) (1/16)#0 (d6da4aa057d377a33250b312b87503e1) [DEPLOYING]. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (1296a920ed168128b0b7d464013297f3) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16) (attempt #0) with attempt id 1296a920ed168128b0b7d464013297f3 and vertex id fd1593b680552266088a4484f9b6d199_14 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id b322193516580134c9554813a11de3e1 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (d6da4aa057d377a33250b312b87503e1) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: FlatMap (FlatMap at ExtractOutput[0]) (1/16)#0 (d6da4aa057d377a33250b312b87503e1) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState 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 INFO: CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (6512e755a6b05a062dabbf4602d77bb2) switched from SCHEDULED to DEPLOYING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution deploy 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: Deploying CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16) (attempt #0) with attempt id 6512e755a6b05a062dabbf4602d77bb2 and vertex id fd1593b680552266088a4484f9b6d199_15 to f4223ff3-ba61-4b02-99fd-f5c1017eb11a @ localhost (dataPort=-1) with allocation id a96056f812ca7354bc80c6e191c65464 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (1/16) (f37c60ccd97cdc93b96835ecf7fe4eb0) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (1/16) (f37c60ccd97cdc93b96835ecf7fe4eb0) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (2/16) (4286ee1de442350659d0201cf56c0d49) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (2/16) (4286ee1de442350659d0201cf56c0d49) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (3/16) (fda6ab6da7686ac5a1bda4d92057123e) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (3/16) (fda6ab6da7686ac5a1bda4d92057123e) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (4/16) (4ac604eaf8c36364bde86fd0e0e1e971) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (4/16) (4ac604eaf8c36364bde86fd0e0e1e971) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (5/16) (0bd2b31046d2e8e007557ce11733b667) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (5/16) (0bd2b31046d2e8e007557ce11733b667) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (6/16) (9e4a2a38883d239af7cca3c9aef867e2) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (6/16) (9e4a2a38883d239af7cca3c9aef867e2) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (7/16) (aa64ef796ae830a3b36eab241a3e01cf) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (7/16) (aa64ef796ae830a3b36eab241a3e01cf) switched from INITIALIZING to RUNNING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl markExistingSlotActive INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot f151eb4538150291de7502281833887b. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (1/16)#0 (f37c60ccd97cdc93b96835ecf7fe4eb0) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (3/16)#0 (fda6ab6da7686ac5a1bda4d92057123e) switched from RUNNING to FINISHED. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.executiongraph.Execution transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: DataSource (Impulse) (8/16) (19e1e6ab6320583a8aa5169347c22162) switched from DEPLOYING to INITIALIZING. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 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) (3/16)#0 (fda6ab6da7686ac5a1bda4d92057123e). INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:54 PM org.apache.flink.runtime.taskmanager.Task transitionState --------------------------- Captured stdout teardown --------------------------- INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 93f10207db9d64fee735a689f12cbdc6. ---------------------------- Captured log teardown ----------------------------- INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: Activate slot 93f10207db9d64fee735a689f12cbdc6. INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:55 PM org.apache.flink.runtime.taskmanager.Task transitionState INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO: CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at core.py:3481>)) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)#0 (4ada94be9d64b70278241d53f336abbf) switched from CREATED to DEPLOYING. INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:569 Started BigQuery job: <JobReference jobId: 'beam_bq_job_QUERY_BQ_EXPORT_JOB_be84d8fc-4_1660578241_248' location: 'US' projectId: 'apache-beam-testing'> bq show -j --format=prettyjson --project_id=apache-beam-testing beam_bq_job_QUERY_BQ_EXPORT_JOB_be84d8fc-4_1660578241_248 INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 15, 2022 3:43:55 PM org.apache.flink.runtime.taskmanager.Task doRun =============================== 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>:632: 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>: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 504.37s (0:08:24) = > 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 10m 9s 133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date Publishing build scan... https://gradle.com/s/hr5u3rg5vqt2o 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]
