See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/804/display/redirect>
Changes:
------------------------------------------
[...truncated 108.48 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(b3d10fc2d10daac64ba39787ab7940fa) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (attempt #0) with attempt id
b3d10fc2d10daac64ba39787ab7940fa and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_2 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id 6f440cf6fd3005e126e19b09272a2c03
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Activate slot dbd03dd48c6c99714c772df4ba7b51b8.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(485c6a323f316af6d3f431a4ab862dab) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16)#0 (ebbcb484c9711058375af46982d0d700) switched from
CREATED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (attempt #0) with attempt id
485c6a323f316af6d3f431a4ab862dab and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_3 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id 35000540980d18af877f49a09309932d
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 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
[3]read_words/Read/{Map(<lambda at iobase.py:908>), SDFBoundedSourceReader}) ->
FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(ebbcb484c9711058375af46982d0d700) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(7bff3c63335cfb4b3d35fd88c7530338) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (5/16) (attempt #0) with attempt id
7bff3c63335cfb4b3d35fd88c7530338 and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_4 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id 7bb74aa098e3fd28c23b1026fa092cef
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(413d79494ccb8134cac492ad6321f4ec) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (attempt #0) with attempt id
413d79494ccb8134cac492ad6321f4ec and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_5 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id 1f4df9e1dcd9c564bd26cec0f49ac5a8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 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
[3]read_words/Read/{Map(<lambda at iobase.py:908>), SDFBoundedSourceReader}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(bd72aa8631afb012ab85f8be8ccd9aee), deploy into slot with allocation id
dbd03dd48c6c99714c772df4ba7b51b8.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(711e709ea50a7351b9f47391a53c655d) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Activate slot aa681bef0ae94697b868e011f8e45c50.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Beam Fn Control client connected with id 2-1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16)#0 (bd72aa8631afb012ab85f8be8ccd9aee) switched from
CREATED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16)#0 (ebbcb484c9711058375af46982d0d700) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task doRun
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:
Loading JAR files for task CHAIN MapPartition (MapPartition at
[3]read_words/Read/{Map(<lambda at iobase.py:908>), SDFBoundedSourceReader}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(bd72aa8631afb012ab85f8be8ccd9aee) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16)#0 (ebbcb484c9711058375af46982d0d700) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16) (attempt #0) with attempt id
711e709ea50a7351b9f47391a53c655d and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_6 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id dbd03dd48c6c99714c772df4ba7b51b8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 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 [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(32284a3c234a9435a189eb3ca57568cd) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (attempt #0) with attempt id
32284a3c234a9435a189eb3ca57568cd and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_7 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id aa681bef0ae94697b868e011f8e45c50
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16)#0 (bd72aa8631afb012ab85f8be8ccd9aee) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16)#0 (bd72aa8631afb012ab85f8be8ccd9aee) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 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 [3]read_words/Read/{Map(<lambda
at iobase.py:908>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(604762ab477f556de0bbcde0e86789d3) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 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 [3]read_words/Read/{Map(<lambda
at iobase.py:908>), SDFBoundedSourceReader}) exceeded the 80 characters length
limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (attempt #0) with attempt id
604762ab477f556de0bbcde0e86789d3 and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_8 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id cd65f820181dc92724979ee722a8dd49
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 2-7
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 2-12
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [3]read corpus/{FilesToRemoveImpulse,
MapFilesToRemove}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(03f65cfb2de2e6c1ced510dd82b7b43a) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM org.apache.flink.runtime.executiongraph.Execution deploy
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Deploying CHAIN MapPartition (MapPartition at [3]read
corpus/{FilesToRemoveImpulse, MapFilesToRemove}) -> FlatMap (FlatMap at
ExtractOutput[0]) (10/16) (attempt #0) with attempt id
03f65cfb2de2e6c1ced510dd82b7b43a and vertex id
b1dbfa61a68ebb01e4122fdf568e6307_9 to 0c1e3c33-b2ab-4ae6-9cde-2e752123c2a5 @
localhost (dataPort=-1) with allocation id 2261560fffe1f334dcb0863735c66598
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 2-2
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:11 AM 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 at
org.apache.flink.runtime.taskmanager.Task.run(Task.java:563)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 AM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Activate slot 2261560fffe1f334dcb0863735c66598.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 AM org.apache.flink.runtime.taskmanager.Task doRun
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Freeing task resources for CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(13b3cf91b36da59b1c2f20b8628486f7).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 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]) (9/16)#0
(e2e78f6d9fcaa102879e67cd5424e4dd) switched from CREATED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 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]) (9/16)#0
(e2e78f6d9fcaa102879e67cd5424e4dd) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 2-104
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 28,
2022 9:44:14 AM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(e2e78f6d9fcaa102879e67cd5424e4dd) switched from DEPLOYING to FAILED with
failure cause: java.io.IOException: Insufficient number of network buffers:
required 2, but only 0 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 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.internalCreateBufferPool(NetworkBufferPool.java:483)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.buffer.NetworkBufferPool.createBufferPool(NetworkBufferPool.java:461)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartitionFactory.lambda$createBufferPoolFactory$0(ResultPartitionFactory.java:279)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 at
org.apache.flink.runtime.io.network.partition.ResultPartition.setup(ResultPartition.java:160)
=============================== 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
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)
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
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
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of RPC that
terminated with:
status = StatusCode.CANCELLED
details = "Multiplexer hanging up"
debug_error_string =
"{"created":"@1661679971.582319345","description":"Error received from peer
ipv6:[::1]:39819","file":"src/core/lib/surface/call.cc","file_line":966,"grpc_message":"Multiplexer
hanging up","grpc_status":1}"
>
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, 6529 deselected, 39 warnings in 535.37s
(0:08:55) =
> 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 38s
133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/eib5ugiv2r3nm
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]
