See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/60/display/redirect?page=changes>
Changes:
[noreply] [BEAM-13738] Reenable ignored SQS test after bumping elasticmq for
fixed
[noreply] fix build status link (#16907)
------------------------------------------
[...truncated 30.45 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(66790244338ac91a9f64bb71ecb26286) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(b5091d261297db813503f26b07679bc2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(a92d973146ad361b6e1c4abf50458bd3) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(ce2f09002f4a1a3909cb2117197d101d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(f98575c1586cb7d66d0bfdc06b5f6be7) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(f6373fbff6b21aa5955b50b206477c6a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(a60017f5aa356bc70077824f5319f56c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(b889e48991a473dce63383fc97af63c0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(fe2b9c3c4673f973c5cdaaa5fec29cbf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]read_words/_PassThroughThenCleanup/Create/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(9b52c60b787dc75cf69d02974b8696f0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(9d18daded8040dfdce65de1ff44e0308) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(16d872383d9d73df7bbf02233fefeeba) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(27879bfb1ca42a5bf666c057e2a772ed) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(e90d6f47466b8e240218622150ab2c30) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(88238cb40a7303c6f68c33903e01a2a9) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(bbe1c839a313ce26043144ba3e27e27c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(7e8d315220f6156e01fd38ae1dd97ea6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(8f57bc0caa146cd275f5483262666ca6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(74bcb349dac7df5bd715c20e67c0dbe4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(1468ed233c770f19f8f59df6fa5bfea7) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(e90601cbac1f320c5e23c899fc6d9b47) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(1ab1e406a1a77710eff7d8fa78903a44) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(8f8800537fe5a2387d1737c68d81e453) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(da76c5da2b7a5da4f2c3e949e218d575) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(d61c0a22485e7af1cea45d2d4b8e2f00) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(bee30a10e99c61988cf5fcebcb607e72) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(2d1d21d623eb448db83ded14546a755d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(27f50a7e194f7b021d92d37d9454cb02) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(b4ce2d6697101a1eee752b7675a422ab) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(40c0796c439ea5ce066a65b49994f85b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(983dedd597f884e9353d92a123147bbf) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(3055a0d79c128d81de0da2ddad33bd20) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(2ffb6e6af66a5d54d8af0d8a74d0c195) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(c0d3b005099e4b4edbfb70b94940f007) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(4a822a961994a7b8f2a2599b08d8387d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(35257ae4005ce28a6363ffa9225c88a0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(aae0cdef704aef4b3c47203f53268642) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(5b065d36fd4f666a7283edaf2e56a5d6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(ad3a1052c4589f7ee6fcea23f170b667) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(d0fd538329d1e32af19e9c976cc9663e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(542e0935d67f03fe691225c3638134c2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]read
corpus/_PassThroughThenCleanup/Create/{FlatMap(<lambda at core.py:3229>),
Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(be275f9952c34a894f8b491e2b0d1b23) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(c1f62649b4d2f10dd5f0dcd73ceb2643) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(165aed44bd735f32d7d5530f4f34be3a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(d08d1fcbb97a49a58112daf1456c8964) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(e9d66840ea1cf9e2e5dada825308493a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(21f9cb59d3031d8b8861ca4ed1f46c42) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(84e286442678275093a67d4f209d786d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(68a73cfb961caf6b730cb2739c62361e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(893d18a280ac609f9eb5236df1159ae8) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(0f18437a7d5cbe7181b26819d9478078) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(238af6a856c4b272b20f9e8c84a8d49e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(644bcec77858183f3b28b1c4c955c78a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (12/16) (45298c41dcf32633ef57885fec138ce5) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (15/16) (89e2c049687210633685b709838e25ea) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (13/16) (ce5d44b4b684c46441616c7d6d6c79a9) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(dbde4778b9d6e78145f0c38ab7e1827a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (7/16) (a612b63bf0f14919e5c8fd38350b98d8) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (5/16) (3aa9be2987a463087bf12d63e690822a) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(acecac5dd659aaf67db08dee326ac45f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(1f1cf7fc9f22fe1afac95fbbb8fef52f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(c1dbbe52403135e44d662ef8442f30b2) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/FlatMap(<lambda at
core.py:3229>)) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(4569ae4e2805962ff56cf3fcd2fa0b74) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (2/16) (4d8caf6c0518ef14543db508239f127f) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (4/16) (c150cf4e401d39f601d5a9adb86395d8) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (3/16) (405709ea1e8015152ef944d9e81761af) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (16/16) (00337f8f14817bfc4296094b58f4a430) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (14/16) (919938c51af343ba0d23d22c08a9c585) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (8/16) (18c19a45c71b1b1fcb4041b28833a198) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (9/16) (bdc6a453566ebc2a7b2fbaf0a148e150) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (10/16) (84202d5da4c66649cc532ee7600b314c) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (11/16) (71c973335da4c020d38869dbf0a4e7cc) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (6/16) (8754657a3f357b9f226ddb2c72807c0f) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (1/16) (8a1d715e4fa02ce3c7dea73327a3ebf5) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/16) (7804b16f2a3b400ea511d1ee44cb4db6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (3/16) (e248f63d2c16d05b6c36ac47cecac4d6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (2/16) (1c7c7e9bdc8624db1ce64e319946424d)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (4/16) (8ed97bbbab000181ccb45f4965e83229)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (5/16) (ef60bddbcaf4bbc24a943e68b7af0238)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (7/16) (53d2170b7cb726c06355fc59d811e06e)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16) (b48a8592c7fff00cfd4b846dc91b8fc1)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16) (fe168b11748326d74e59e36d03143774)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (10/16) (60534f8ecdc403143792d99275fecb0a)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (9/16) (7fd4ce9ae5241c571e7b18540387ee30)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (11/16) (5f7c9df16ba25a8c0ff49544830d4ed5)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (13/16) (8b8aa986da132ee89c8329526efe2ade)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (12/16) (fb646f23eee765268dab220fcbf8342b)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16) (0561f2c4a0979f3d7a4acf9592bac962)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(dacd45bd406d38cee7f2ee490c66a3c5) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (16/16) (be81a7ba0af2f299c4e3e0c44767c4d6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(ffeca09dc7659d3b80e50bae857cb50d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]create groups/Map(decode)) -> FlatMap
(FlatMap at ExtractOutput[0]) (15/16) (7a804f69855b62f8467ef04f587cb06c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(c0330934e2e5777da2b661fc9c3c7fd3) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(a35b0be1bebb2e6c1305b85f793c2573) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(26c1924f67549fd45f9e6a12333121eb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(28e45a494355eb36c526cb517a52d6da) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(dfe0c631f9fc539875a393311c234ddb) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(b7b79b9c7c8d87a0fa6de75e439c26a4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(933774c0499201396e3be7f5c43c737e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(6f3db569e03e42e938923ff543bb87f5) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(93bc6af3c2a243f5455e03961a15f5d6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(65d4cb5f4a6d7e9a6f22fddba8507c8a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(e314000575080d098edd7f440f4e1f62) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(30643c04ec31b3b1a90466b5c1494c92) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(9dc7520d6d3ee4464843b7a88e5e01a6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:14:00 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_corpus/{FlatMap(<lambda at
core.py:3229>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(6d789ca112c5bc1a1214f4cc6e3064f4) switched from RUNNING to FINISHED.'
INFO root:bigquery_tools.py:625 Job status: DONE
INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:552 Started
BigQuery job: <JobReference
jobId:
'beam_bq_job_EXPORT_BQ_EXPORT_JOB_33759b27-6_1645553641_106'
location: 'US'
projectId:
'apache-beam-testing'>
bq show -j
--format=prettyjson --project_id=apache-beam-testing
beam_bq_job_EXPORT_BQ_EXPORT_JOB_33759b27-6_1645553641_106
INFO root:bigquery_tools.py:625 Job status: RUNNING
INFO root:bigquery_tools.py:625 Job status: DONE
INFO apache_beam.io.gcp.bigquery_tools:bigquery_tools.py:552 Started
BigQuery job: <JobReference
jobId:
'beam_bq_job_EXPORT_BQ_EXPORT_JOB_81a13c88-7_1645553642_187'
location: 'US'
projectId:
'apache-beam-testing'>
bq show -j
--format=prettyjson --project_id=apache-beam-testing
beam_bq_job_EXPORT_BQ_EXPORT_JOB_81a13c88-7_1645553642_187
INFO root:bigquery_tools.py:625 Job status: RUNNING
> Task :sdks:python:test-suites:portable:py37:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:12:17 PM
org.apache.beam.sdk.fn.data.BeamFnDataGrpcMultiplexer$InboundObserver
onCompleted'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Hanged up for unknown endpoint.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 22,
2022 6:12:17 PM
org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory$WrappedSdkHarnessClient
close'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Error cleaning up servers urn: "beam:env:external:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'payload: "\\n\\021\\n\\017localhost:35445"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:bytes:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:string_utf8:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:kv:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:bool:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:varint:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:double:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:iterable:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:timer:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:interval_window:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:length_prefix:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:global_window:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:windowed_value:v1"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'capabilities: "beam:coder:param_windowed_value:v1"'
java.lang.OutOfMemoryError: GC overhead limit exceeded
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]
