See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/26/display/redirect>
Changes:
------------------------------------------
[...truncated 15.65 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (8/16)#0 a66dbe5af3713b943fa142b61e50a16d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(eef24fce56ce669253072afac9d1da14) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (10/16)#0 1a1df8e47d1f1b34af5b4f8bb25066be.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(811619263a756179242c3491b8fac608) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (9/16)#0 32b24a63a0f428087211d3316270ed2b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(c8a0223f71496736ccddc0c9c754c974) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (12/16)#0 cb8438ba1476cc47c93cdc0a5b106f7f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(c4e66bccdebe29f315d89949db83413d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (11/16)#0 bbde0a65a23e1f6ca2ac0788dc620ce7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(0de1bac1fbdef038b17d1b54bf490605) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (1/16)#0 3b29a073bc2ed128e0946be146a3c822.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (3/16)#0 d4f56806df4b347e9d66e776f26621a3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (13/16)#0 0e7b1b3c651c0f921c7906f88374a388.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(72fba8d95021b985e4cff96d0733d26c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (14/16)#0 f9a60b5a98c1118778fffd66c37fe47e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(da44e7f403e7e625aeb2db659e86d746) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (7/16)#0 1d26905a693e0e63f274849857338eb4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(c2f4f839ea49e169765b9a8c4f5fe708) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (4/16)#0 bbf863542922bf2d24304b6d85e7874a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (2/16)#0 4d8f0a9d3ac1297dffaf3b4903a71606.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (6/16)#0 fd88900458b5a3fc3bcc68b365cf8b42.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (15/16)#0 217c4d58d619a83ec2e0cff6fc0d76f3.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (5/16)#0 22217fd32fd899605c1cdb5c593a7617.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (8/16)#0 c534ea41f1a6772ab51124809be0e4dd.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (10/16)#0
18af3d27c20ac52aabc5c765c9eaa95f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (11/16)#0
803a487b50c8776115eea42cecc52924.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(a9f849558a06ea2326c0929e5ed016b4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (9/16)#0 cc0f636420ade40ff3e86d1858d5c9c4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (12/16)#0
1688f1d23ad5fa203d1591947cf9b6df.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (14/16)#0
47df4be1ba8a246a71918b61a7717aca.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (13/16)#0
3232896e39ddcc4a0ab687093eb6b0c6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (15/16)#0
be93eed1ddd7f82d0da7194502bf152f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task DataSink (DiscardingOutput) (16/16)#0
5fa2b5fb934e87142a6be5c9f207085e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (16/16)#0 dda7814f11aa0e626380ad7cdc97a05a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/WaitForCopyJobs)
-> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(6bafa5da2981aa2b36467e16610c1318) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (7/16) (76535c64c187fb33fce59bf87537634f) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (3/16) (668548b6974cae56d69be00f501f2314) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (9/16) (b75d65444065582c7739ef0f9daa21e2) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (10/16) (d21df28aa3ae68d7a28b83b41fabae1f) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (4/16) (f3f800aa53941820b74fab55b55b9e2c) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (11/16) (75afce75fa8ac42c69a55d09087e2f8d) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (6/16) (b11e1fd3a16aa148ffbbffa9fcf877f5) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (12/16) (997f198da7070e198b57ad69ddcbb61c) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (8/16) (8b6efae0aa0e10fe5438a564dd545d7a) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (5/16) (519214adc699a92432ec6bd1363e25d9) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (13/16) (c03585693b82ae444bf59fb7708dc063) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (2/16) (4588422f4854652a733e2c5cefb16710) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (15/16) (c29eca501be7daf8f1a30b51eb3c9d0a) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (1/16) (61ec285b8fe75d167a913b0936ad0dab) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (14/16) (e441f12ac8bc0c3e4691b17c7debf4fb) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(5/16) (f4a666bef1cf9c37826e1c3fed3e1586) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 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]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{PassTables,
AddUselessValue}) -> FlatMap (FlatMap at ExtractOutput[0]) -> Map (Key
Extractor) -> GroupCombine (GroupCombine at GroupCombine:
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
-> Map (Key Extractor) (16/16) (2d9735a9672d277576fd7b84ccf9b41d) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(4/16) (c162586c51288058360d1218151580cd) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(7/16) (dbd4fa49076bbd1ac6c49f11762c6ef6) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(1/16) (9ec744a3ae471ec1617bf6f71256a13b) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(2/16) (c093bad077a8bf218e57c442954fed36) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(3/16) (501a279f6f8de88bb324b52462cf8a44) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(8/16) (1d344b4fa1349746da22cdc2b35732b7) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(6/16) (0d16e6d04e01e8650aa0498a24bbbcbd) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(9/16) (06f333c3abdee87ca339f5430d97efa0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(11/16) (5c03227986c8a01b11eb53e7f63a2c1f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(10/16) (ec3794c4e740722e806031117bccdebe) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(12/16) (70ba280d4dad96046d9f75677b0d9da9) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(14/16) (a4fcfc88a7b019e3df1bdcdabcd9f3a4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(15/16) (ae24dc983250a041ebedb4bb8dfddbfc) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(13/16) (a78407fa2cefe4a523c635f36e755327) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
GroupReduce (GroupReduce at
WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/DeduplicateTables)
(16/16) (38eee89e6991a198d2974a2589c822af) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (1/16) (fb92e3ebb77be1071442707ef49b84f8) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (2/16) (fcfffe344fcac027c8a83126de86911e) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (4/16) (cc53f73a69f62a477ba5176059948017) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (3/16) (cfd6514f5bd4e38386cf08dc779ba209) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (5/16) (88eefc616574ed368e1b255854cebb30) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (7/16) (2aa325867ebff7154ca70ddab32b7b03) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (6/16) (3d25b2205d07b8e1cb4fa47779eb1217) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (8/16) (a66dbe5af3713b943fa142b61e50a16d) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (10/16) (1a1df8e47d1f1b34af5b4f8bb25066be) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (9/16) (32b24a63a0f428087211d3316270ed2b) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (12/16) (cb8438ba1476cc47c93cdc0a5b106f7f) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (11/16) (bbde0a65a23e1f6ca2ac0788dc620ce7) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (1/16) (3b29a073bc2ed128e0946be146a3c822) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (3/16) (d4f56806df4b347e9d66e776f26621a3) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=15}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (13/16) (0e7b1b3c651c0f921c7906f88374a388) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (14/16) (f9a60b5a98c1118778fffd66c37fe47e) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (7/16) (1d26905a693e0e63f274849857338eb4) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=14}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (4/16) (bbf863542922bf2d24304b6d85e7874a) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=13}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (2/16) (4d8f0a9d3ac1297dffaf3b4903a71606) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=12}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (6/16) (fd88900458b5a3fc3bcc68b365cf8b42) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=11}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (15/16) (217c4d58d619a83ec2e0cff6fc0d76f3) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (5/16) (22217fd32fd899605c1cdb5c593a7617) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=10}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (8/16) (c534ea41f1a6772ab51124809be0e4dd) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=9}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (10/16) (18af3d27c20ac52aabc5c765c9eaa95f) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=8}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (11/16) (803a487b50c8776115eea42cecc52924) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=7}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (9/16) (cc0f636420ade40ff3e86d1858d5c9c4) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=6}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (12/16) (1688f1d23ad5fa203d1591947cf9b6df) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=5}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (14/16) (47df4be1ba8a246a71918b61a7717aca) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=4}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (13/16) (3232896e39ddcc4a0ab687093eb6b0c6) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=3}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (15/16) (be93eed1ddd7f82d0da7194502bf152f) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=2}]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
DataSink (DiscardingOutput) (16/16) (5fa2b5fb934e87142a6be5c9f207085e) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/RemoveTempTables/{GetTableNames,
Delete}) (16/16) (dda7814f11aa0e626380ad7cdc97a05a) switched from RUNNING to
FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:05:28 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Received resource requirements from job ff0b37a59a8475ef184c30c882e14bfd:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=1}]'
> Task :sdks:python:test-suites:portable:py39:flinkExamples
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:03:57 PM org.apache.beam.runners.fnexecution.data.GrpcDataService data'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Beam Fn Data client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 12,
2022 12:03:57 PM org.apache.flink.runtime.taskmanager.Task transitionState'
FAILURE: Build failed with an exception.
* What went wrong:
GC overhead limit exceeded
* Try:
> Run with --info or --debug option to get more log output.
> Run with --scan to get full insights.
* Exception is:
java.lang.OutOfMemoryError: GC overhead limit exceeded
* Get more help at https://help.gradle.org
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]
