See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/750/display/redirect?page=changes>
Changes:
[noreply] fix minor unreachable code caused by log.Fatal (#22618)
------------------------------------------
[...truncated 109.00 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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)
(803a160826e76cd09adb38787804f1f4) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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
803a160826e76cd09adb38787804f1f4 and vertex id
1734dc3164ff5170b7812bc231d64489_10 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id 2f67ebff067be8296c1c0344dec42c7e
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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)
(6f597c4d48e216976c53c5ce2ac11069) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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
6f597c4d48e216976c53c5ce2ac11069 and vertex id
1734dc3164ff5170b7812bc231d64489_11 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id 8069d7e0961af193c340c2fa753f41b8
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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)
(11fded56830b6a0cfa823df1e40589d2) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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
11fded56830b6a0cfa823df1e40589d2 and vertex id
1734dc3164ff5170b7812bc231d64489_12 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id 77261de968b1b73948465102aabbbfc4
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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)
(e2ac58323ec04e27faf8bdb4613a4fec) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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
e2ac58323ec04e27faf8bdb4613a4fec and vertex id
1734dc3164ff5170b7812bc231d64489_13 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id 7bf4d5529c1a8c8e1a25b5264159a731
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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)
(ebe423f11067c8568f8cb14f4916670b) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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
ebe423f11067c8568f8cb14f4916670b and vertex id
1734dc3164ff5170b7812bc231d64489_14 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id a6221aa50e102b8e796d1204e8df4e86
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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]) (16/16)
(26728589a6496691bd5ff6ee5936304e) switched from SCHEDULED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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]) (16/16) (attempt #0) with attempt id
26728589a6496691bd5ff6ee5936304e and vertex id
1734dc3164ff5170b7812bc231d64489_15 to d6ab3685-7af6-465b-b392-43bcc93dd48a @
localhost (dataPort=-1) with allocation id 4510d3a8e132ab05980ae1b69e3dafcf
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (1/16) (d9a8d04dce5c1bc7dfa5d397b644da50) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (1/16) (d9a8d04dce5c1bc7dfa5d397b644da50) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (2/16) (74aefdb9fbd28b4ba80c20c7bcc1d124) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (2/16) (74aefdb9fbd28b4ba80c20c7bcc1d124) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (3/16) (26deb45fdd44298d47e9d95aecc14927) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (3/16) (26deb45fdd44298d47e9d95aecc14927) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (4/16) (14fced211c4644b7c607500d78258b33) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (4/16) (14fced211c4644b7c607500d78258b33) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (5/16) (edf07476aca4d923f228a86046041534) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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 12 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:
DataSource (Impulse) (5/16) (edf07476aca4d923f228a86046041534) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM 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:
DataSource (Impulse) (7/16) (7fe8216422599cc18d775c158ce1438a) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (7/16) (7fe8216422599cc18d775c158ce1438a) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (6/16) (eca861da72f73eec42beb69b3be893da) switched from
DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (6/16) (eca861da72f73eec42beb69b3be893da) switched from
INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM 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]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(1251a21d5ad8e2ae21cab3bc68603ec4) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(78f67a5ef0ef0f83d2fd4bdb496219a3) switched from DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)#0
(78f67a5ef0ef0f83d2fd4bdb496219a3) switched from INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
The operator name MapPartition (MapPartition at
[2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)})
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(1251a21d5ad8e2ae21cab3bc68603ec4) switched from DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)#0
(1251a21d5ad8e2ae21cab3bc68603ec4) switched from INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
The operator name MapPartition (MapPartition at
[2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)})
exceeded the 80 characters length limit and was truncated.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (7/16)#0 (7fe8216422599cc18d775c158ce1438a) switched from
RUNNING to FINISHED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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) (7/16)#0
(7fe8216422599cc18d775c158ce1438a).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
DataSource (Impulse) (2/16)#0 (74aefdb9fbd28b4ba80c20c7bcc1d124) switched from
RUNNING to FINISHED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 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) (2/16)#0
(74aefdb9fbd28b4ba80c20c7bcc1d124).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 3-11
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 3-35
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 3-34
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 3-33
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl
markExistingSlotActive
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Activate slot 554532aa0cf947bf6a0d513855463faa.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(0bea31268e66103b13fdcab10144cc39) switched from CREATED to DEPLOYING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM 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]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) ->
FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(0bea31268e66103b13fdcab10144cc39) [DEPLOYING].
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(0bea31268e66103b13fdcab10144cc39) switched from DEPLOYING to INITIALIZING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)#0
(0bea31268e66103b13fdcab10144cc39) switched from INITIALIZING to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Received task CHAIN MapPartition (MapPartition at
[2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)}) ->
FlatMap (FlatMap at ExtractOutput[0]) (9/16)#0
(3f176b809cf68fda6d87156ae888a7cc), deploy into slot with allocation id
554532aa0cf947bf6a0d513855463faa.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:07 PM org.apache.flink.runtime.metrics.groups.TaskMetricGroup
getOrAddOperator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
The operator name MapPartition (MapPartition at
[2]create_ignore_word/{FlatMap(<lambda at core.py:3481>), Map(decode)})
exceeded the 80 characters length limit and was truncated.
--------------------------- Captured stdout teardown ---------------------------
FAILED [ 56%]
---------------------------- Captured log teardown -----------------------------
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemote'. Metric will not be reported.[, taskmanager,
d6ab3685-7af6-465b-b392-43bcc93dd48a, BeamApp-jenkins-0814214356-44fff4c5,
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:08 PM org.apache.flink.runtime.metrics.groups.AbstractMetricGroup
addMetric
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 WARNING:
Name collision: Group already contains a Metric with the name
'numBuffersInRemotePerSecond'. Metric will not be reported.[, taskmanager,
d6ab3685-7af6-465b-b392-43bcc93dd48a, BeamApp-jenkins-0814214356-44fff4c5,
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)), 8]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:08 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
getProcessBundleDescriptor request with id 3-88
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:08 PM org.apache.flink.runtime.taskexecutor.TaskExecutor submitTask
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
Received task MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (9/16)#0
(ccf677d40ac0eed33f407bbf4e738833), deploy into slot with allocation id
554532aa0cf947bf6a0d513855463faa.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 Aug 14,
2022 9:44:08 PM org.apache.flink.runtime.taskmanager.Task transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:132 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (9/16)#0
(ccf677d40ac0eed33f407bbf4e738833) switched from CREATED to DEPLOYING.
=============================== 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 487.60s
(0:08:07) =
> Task :sdks:python:test-suites:portable:py37:flinkExamples FAILED
FAILURE: Build completed with 2 failures.
1: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 240
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py39:flinkExamples'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================
2: Task failed with an exception.
-----------
* Where:
Script
'<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/ws/src/sdks/python/test-suites/portable/common.gradle'>
line: 240
* What went wrong:
Execution failed for task
':sdks:python:test-suites:portable:py37:flinkExamples'.
> Process 'command 'sh'' finished with non-zero exit value 1
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
==============================================================================
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.4/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 9m 51s
133 actionable tasks: 87 executed, 44 from cache, 2 up-to-date
Publishing build scan...
https://gradle.com/s/mxmlcdfcrpmvw
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]
