See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/109/display/redirect>
Changes:
------------------------------------------
[...truncated 21.81 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (15/16) (32d6cfecbd23d870bd09822e8ecc0b07) switched from
CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSource (Impulse) (16/16) (98e0c3fc9ccab01197517f8fb5ca8977) switched from
CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (1/16) (1ebec2f3fdf2b94b80c926809becbc42)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (2/16) (80a56c821ff30f6c4382f0d3cea4cac6)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (3/16) (6fbb440d74051a9bacea3383f2cbf7d5)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (4/16) (5d8599f83cb125cce794474a9e741561)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (5/16) (f6ec85275ab353a23e12e790b7b73a56)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (6/16) (86af83ad3ef5c314de912444873f31dd)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (7/16) (11b6f2ca57f5da4d326d1ceef13e1ade)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (8/16) (7df09213c778dbd42f49d90647d2fbc7)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (9/16) (b49485f2d51229ed92f5d17e183d4e8c)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (10/16) (dc938d516d3fdc3edc37ffa4d8eec8ee)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (11/16) (08c65e9222088bb4015e852f19bae4fe)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (12/16) (c2815fc1cb4f78a7af87418f2d57ede4)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (13/16) (e3af2e0cb0c26f3b244be8869c5d94dc)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (14/16) (1ec7a87357970e0a2c006e01ba295281)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (15/16) (362071bac98352ff424bdb209bd1184e)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[1]EstimatePiTransform/Initialize/FlatMap(<lambda at core.py:3229>)) -> FlatMap
(FlatMap at ExtractOutput[0]) (16/16) (4a6f1da7bab792845ed0e0936cd11660)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (1/16) (51247d6a085e3cdf4d1cba28a4a99980) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (2/16) (e1cbbf56f28815d9136837a8306e4561) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (3/16) (450f55da69b1c2a0781ffee0fb982f25) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (4/16) (63b0d9ab2379d1ee17e65afee8809c25) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (5/16) (aee05b3fa9eca26936122d1ec30268f1) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (6/16) (e132d7819f3dcb4dd5d3d224d31c5c95) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (7/16) (ff3ec3c4431ceb47236211ccc24eec1e) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (8/16) (f3e0e4f0514e01a4801e6aff9914325c) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (9/16) (a59ae603610bb5aaf3c15167ca791fe8) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (10/16) (43a061ba743c30467c943045eecb2768) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (11/16) (913e538cbae76be6f2c84681d3bdea11) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (12/16) (209423dc2ce81ea87c56b0028ca0a86d) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (13/16) (2954c3685fbea2b408c73040d8737b5e) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (14/16) (18b98a046aff80e5ec00921772289962) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (15/16) (3437cc8b294d81ae7e1eb0dd215e2c17) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Partition (16/16) (fc255e143869683b01777eb5dba17a01) switched from CREATED to
SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (1/16)
(25877063b6dfbbd6e8b99c253014688b) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (2/16)
(760a87a4737f438cb2a454e60d5a9a4b) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (3/16)
(f1d9755288491810c88215fab443ad8a) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (4/16)
(3bf48e7cca356fde4d8bb1041cfc5f02) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (5/16)
(d609912c0f3689a358ec00d300e894e9) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (6/16)
(d7dfed1eae9558db3f80c33f2ce4962e) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (7/16)
(777463b95359d8bb06eebc3846cbf202) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (8/16)
(3d1a333be72b2952d66c761c2208db99) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (9/16)
(61a741361431daeacc08334871d6fe31) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (10/16)
(ab13f83b50490bb46c62e4efb9110d53) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (11/16)
(2d4eccd329713ba368233b32e7109558) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (12/16)
(dc8e9db65d41fa977b012269039bd02e) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (13/16)
(8b6e63364145d4be157b41be8955825b) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (14/16)
(24cfe1fbeafe2137894d4f05c2df2442) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (15/16)
(072a54f6020296f7dad74bc75b1ddba5) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]EstimatePiTransform/{Initialize, Run
trials, Sum}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key Extractor)
-> GroupCombine (GroupCombine at GroupCombine:
EstimatePiTransform/Sum/CombinePerKey/Group) -> Map (Key Extractor) (16/16)
(e7c5428eff8acbf0c412ff99c917096b) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (1/16)
(8faef12102ee026f11b643b6cbe16fa2) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (2/16)
(cd412ea72487e8c555f5f3cc877433c6) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (3/16)
(c2fe5fb706372f290f4698123fed4143) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (4/16)
(2abc09ae249517dd41b51c9b327cd038) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (5/16)
(81af4c2c5c53658e204329eca9bc147d) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (6/16)
(6242fdc316204c009657f2d3731158e7) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (7/16)
(8ae65fea5f4646ea310f8b711c240aca) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (8/16)
(607e9e36c837fb1e52401d996e8779be) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group) (9/16)
(bf148ccc829685ec8cad8e5c14eb4fa6) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(10/16) (f6fb5a11d842dec82f5968e40c8d04ee) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(11/16) (2f4427a48af12f2a16662280df95d513) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(12/16) (8b1dbe8ef1bf44b5dfe20c00c5c4f767) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(13/16) (4dfed2b71ebd819b433f8442d87e2016) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(14/16) (756c899afb6bef3ff885400df2508d63) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(15/16) (6e16383d0723571be19abb1d888b2537) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at EstimatePiTransform/Sum/CombinePerKey/Group)
(16/16) (781a8c5a3f7c85e3e1c2267f83b666dc) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/16) (3ad994e127461cea6e92681e8a153505)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (2/16) (e6fa5da1eebb95c5afd8ff9d51d9bc11)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (3/16) (fc82124665b65c2d51f4e466e7cbf890)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (4/16) (7645dc7eb8bc2229adb8b102a6f3a205)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (5/16) (4adff17e825bd26cdaf3afab2eaf7ded)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (6/16) (28e382ac957cc4fbbca69c1e82c05f00)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16) (47928596195a1a1240e22eb6bc6e54b6)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (8/16) (82138721471e5f48679ac4b72152cf0c)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (9/16) (9854fe06e1b1e2f13c9db9e5ebbaba87)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(f1aed0808c9059c3ae8a4760ae3fd879) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(212a01418ca0babb0878fbaba068d782) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(6d61b7a7785475411b1a2008b113f059) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(ed70172b8901658ab5c49f0d5d680acc) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(4c8c9a21e0bc2b3da574406eac44af05) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(ce28e39e542ec659d04f4e237ee9470e) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [4]{EstimatePiTransform, WriteToText}) ->
FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(c7b43cb469419e554d38f6a59c107496) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(1/16) (951ae6b519c99e2aa7cbaad47f39f978) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(2/16) (8fe876df77d22de9ac18a104bd745454) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(3/16) (a8827f7712377137fdc6ff52bf794271) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(4/16) (2d83cf2bf330c16518abe3a1eb37117f) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(5/16) (7d3013ec703e5933ae5075476ea6d3e7) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(6/16) (30794799a9125572d4ea82dbf4e40c0d) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(7/16) (54a2b3fcc4769bea14e0a95680fd47d4) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(8/16) (d77bc1fbf76fcc7d5c81585976347066) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(9/16) (531c0808243ba08ce43547c2d38dd234) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(10/16) (c6ad4bd7afcb5c9810eb328f78f9213c) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(11/16) (c9676b5be341382c2003eadc4f4ffd89) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(12/16) (dead60eac601dffaece31b498619bc00) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(13/16) (b579d6be325976440dba4987f2bc7758) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(14/16) (ed3cfda0fcc5b57d5068ee2a60bfad6a) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(15/16) (0e349ae642ed192fd2a5b5bf4244ecaa) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at
[2]WriteToText/Write/WriteImpl/{WriteBundles, Pair}) -> FlatMap (FlatMap at
ExtractOutput[0]) -> Map (Key Extractor) -> GroupCombine (GroupCombine at
GroupCombine: WriteToText/Write/WriteImpl/GroupByKey) -> Map (Key Extractor)
(16/16) (8662819d6565311f67523f225f1f55f5) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (1/16)
(edd4eb033ce882ae271beb0f983af68c) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (2/16)
(88376236dabe9c8131a190fa90913e60) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (3/16)
(d5da37328b1f40641f7f2d1c8cf8168f) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (4/16)
(26c9acf8f983c76b221ddbcf64ed5c2e) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (5/16)
(166d570bc068245a8d37b61a3858c348) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (6/16)
(e0bb5a217a2f28469ce4638e555a6627) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (7/16)
(da9284159df3ed7ce2fc75525ddc84d1) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (8/16)
(68896f233b4c8ca05ceede7c230338d5) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (9/16)
(79b0244e91a08019d9051da1acfd2147) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (10/16)
(61a4f123bcf759acecc7ebb09c644b08) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (11/16)
(763464a5594aae6746ff83fc1f8ed94a) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (12/16)
(cbc7a78048b05cbfebe7d9987e233252) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (13/16)
(0063a37f566090fccae24de6283bb480) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (14/16)
(1a2eae4382ed2bd4cf73bc6ff0a2378c) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (15/16)
(eb99ab3483366f56dcf6eff7d36bde11) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at WriteToText/Write/WriteImpl/GroupByKey) (16/16)
(3fa4d8b3ae0316092a58d4ce57c1fb4f) switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (1/16) (c387bc92e9e03855e2b4fc62352d112c)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (2/16) (6b86e3c7784fa4204dfe4618a6832a7c)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (3/16) (16396959f2918abbab48c1637eeb1581)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (4/16) (cf2b78a5c9c0a8ff42071d0d2c7a42b5)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (5/16) (16ea3ebeddc64db381df37d2e00b4bc6)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (6/16) (8658ff30a71de230a6dea638df4766e1)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (7/16) (74f63feb44b5d947ab114199e4bd4a33)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (8/16) (a8b34078ebb6286214091481768443ac)
switched from CREATED to SCHEDULED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Mar 07,
2022 12:07:43 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
CHAIN MapPartition (MapPartition at [1]WriteToText/Write/WriteImpl/Extract) ->
FlatMap (FlatMap at ExtractOutput[0]) (9/16) (a16f307888d2aee9b40838365e928905)
switched from CREATED to SCHEDULED.'
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]
