See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/2407/display/redirect?page=changes>
Changes:
[noreply] [Java BQ] Storage API streaming load test (#28264)
------------------------------------------
[...truncated 20.62 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Created execution graph cce971133d20fb376be74ab392e8fe93 for job
bf38f22c64abcd41dc5c7987a938451d.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:53 PM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Running initialization on master for job BeamApp-jenkins-1003160844-a5b6746d
(bf38f22c64abcd41dc5c7987a938451d).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:53 PM
org.apache.flink.runtime.executiongraph.DefaultExecutionGraphBuilder buildGraph
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Successfully ran initialization on master in 3 ms.
WARNING root:subprocess_server.py:95 Waiting for grpc channel to be ready at
localhost:50029.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM
org.apache.flink.runtime.scheduler.adapter.DefaultExecutionTopology
generateNewPipelinedRegions
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Built 67 new pipelined regions in 31 ms, total 67 pipelined regions currently.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.scheduler.DefaultScheduler <init>
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Using failover strategy
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy@53e55e9b
for BeamApp-jenkins-1003160844-a5b6746d (bf38f22c64abcd41dc5c7987a938451d).
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM
org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService
confirmLeader
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received confirmation of leadership for leader
akka://flink/user/rpc/jobmanager_3 ,
session=7e0112e9-c9b5-4dae-a3ff-61cfda104c8c
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.jobmaster.JobMaster startJobExecution
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Starting execution of job 'BeamApp-jenkins-1003160844-a5b6746d'
(bf38f22c64abcd41dc5c7987a938451d) under job master id
a3ff61cfda104c8c7e0112e9c9b54dae.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.scheduler.DefaultScheduler
startSchedulingInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Starting scheduling with scheduling strategy
[org.apache.flink.runtime.scheduler.strategy.PipelinedRegionSchedulingStrategy]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.DefaultExecutionGraph
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Job
BeamApp-jenkins-1003160844-a5b6746d (bf38f22c64abcd41dc5c7987a938451d) switched
from state CREATED to RUNNING.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (1/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_0_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (1/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_0_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (2/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_1_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (2/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_1_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (3/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_2_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (3/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_2_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (4/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_3_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (4/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_3_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (5/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_4_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (5/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_4_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (6/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_5_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (6/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_5_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (7/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_6_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (7/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_6_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (8/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_7_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (8/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_7_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (9/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_8_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (9/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_8_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (10/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_9_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (10/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_9_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (11/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_10_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (11/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_10_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (12/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_11_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (12/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_11_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (13/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_12_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (13/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_12_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (14/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_13_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (14/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_13_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (15/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_14_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (15/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_14_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (16/16)
(cce971133d20fb376be74ab392e8fe93_fbe3e60675572df3fd37685c0030e41c_15_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[6]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/{ImpulseSingleElementPC,
LoadJobNamePrefix, CopyJobNamePrefix, GenerateFilePrefix,
SchemaModJobNamePrefix}) (16/16)
(cce971133d20fb376be74ab392e8fe93_b1496aabd7fb08122cf748a4aee6f0e5_15_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (1/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_0_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (1/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_0_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (1/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_0_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (2/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_1_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (2/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_1_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (2/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_1_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (3/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_2_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (3/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_2_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (3/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_2_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (4/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_3_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (4/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_3_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (4/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_3_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (5/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_4_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (5/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_4_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (5/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_4_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (6/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_5_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (6/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_5_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (6/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_5_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (7/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_6_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (7/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_6_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (7/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_6_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (8/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_7_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (8/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_7_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (8/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_7_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (9/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_8_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (9/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_8_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (9/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_8_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (10/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_9_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (10/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_9_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (10/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_9_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (11/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_10_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (11/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_10_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (11/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_10_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (12/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_11_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (12/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_11_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (12/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_11_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (13/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_12_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (13/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_12_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (13/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_12_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (14/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_13_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (14/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_13_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (14/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_13_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (15/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_14_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (15/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_14_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (15/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_14_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSource (Impulse) (16/16)
(cce971133d20fb376be74ab392e8fe93_e24bbb2036e460cc168768cec1d60ff1_15_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[2]WriteTeamScoreSums/WriteToBigQuery/BigQueryBatchFileLoads/ImpulseEmptyPC/{FlatMap(<lambda
at core.py:3759>), Map(decode)}) (16/16)
(cce971133d20fb376be74ab392e8fe93_4044981a46db79f6abaa06a17cdbd681_15_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (16/16)
(cce971133d20fb376be74ab392e8fe93_68aa4f6324099cb6266c30ce883e570c_15_0)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.jobmaster.JobMaster
connectToResourceManager
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Connecting to ResourceManager
akka://flink/user/rpc/resourcemanager_1(a539ed289f50806b4d90f56b97ec46b6)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.registration.RetryingRegistration
lambda$startRegistration$0
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Resolved ResourceManager address, beginning registration
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.resourcemanager.ResourceManager
registerJobMaster
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Registering job manager
a3ff61cfda104c8c7e0112e9c9b54dae@akka://flink/user/rpc/jobmanager_3 for job
bf38f22c64abcd41dc5c7987a938451d.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.resourcemanager.ResourceManager
registerJobMasterInternal
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Registered job manager
a3ff61cfda104c8c7e0112e9c9b54dae@akka://flink/user/rpc/jobmanager_3 for job
bf38f22c64abcd41dc5c7987a938451d.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.jobmaster.JobMaster
establishResourceManagerConnection
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
JobManager successfully registered at ResourceManager, leader id:
a539ed289f50806b4d90f56b97ec46b6.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM
org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager
processResourceRequirements
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Received resource requirements from job bf38f22c64abcd41dc5c7987a938451d:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=16}]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.taskexecutor.TaskExecutor requestSlot
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Receive slot request 17e1f8df8d42049ba2c211886a6d2b4c for job
bf38f22c64abcd41dc5c7987a938451d from resource manager with leader id
a539ed289f50806b4d90f56b97ec46b6.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.taskexecutor.TaskExecutor allocateSlot
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
Allocated slot for 17e1f8df8d42049ba2c211886a6d2b4c.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 03,
2023 4:21:54 PM org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService
addJob
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO: Add
job bf38f22c64abcd41dc5c7987a938451d for job leader monitoring.
FATAL: command execution failed
hudson.remoting.ChannelClosedException: Channel
"hudson.remoting.Channel@417cc5f0:apache-beam-jenkins-5": Remote call on
apache-beam-jenkins-5 failed. The channel is closing down or has closed down
at hudson.remoting.Channel.call(Channel.java:993)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy141.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207)
at hudson.Launcher$ProcStarter.join(Launcher.java:524)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:321)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:814)
at hudson.model.Build$BuildExecution.build(Build.java:199)
at hudson.model.Build$BuildExecution.doRun(Build.java:164)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:522)
at hudson.model.Run.execute(Run.java:1896)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
Caused by: java.io.IOException: Unexpected termination of the channel
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:75)
Caused by: java.io.EOFException
at
java.base/java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2911)
at
java.base/java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3406)
at
java.base/java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:932)
at
java.base/java.io.ObjectInputStream.<init>(ObjectInputStream.java:375)
at
hudson.remoting.ObjectInputStreamEx.<init>(ObjectInputStreamEx.java:49)
at hudson.remoting.Command.readFrom(Command.java:142)
at hudson.remoting.Command.readFrom(Command.java:128)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:35)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
FATAL: Channel "hudson.remoting.Channel@417cc5f0:apache-beam-jenkins-5": Remote
call on apache-beam-jenkins-5 failed. The channel is closing down or has closed
down
java.io.EOFException
at
java.base/java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2911)
at
java.base/java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3406)
at
java.base/java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:932)
at
java.base/java.io.ObjectInputStream.<init>(ObjectInputStream.java:375)
at
hudson.remoting.ObjectInputStreamEx.<init>(ObjectInputStreamEx.java:49)
at hudson.remoting.Command.readFrom(Command.java:142)
at hudson.remoting.Command.readFrom(Command.java:128)
at
hudson.remoting.AbstractSynchronousByteArrayCommandTransport.read(AbstractSynchronousByteArrayCommandTransport.java:35)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:61)
Caused: java.io.IOException: Unexpected termination of the channel
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:75)
Caused: hudson.remoting.ChannelClosedException: Channel
"hudson.remoting.Channel@417cc5f0:apache-beam-jenkins-5": Remote call on
apache-beam-jenkins-5 failed. The channel is closing down or has closed down
at hudson.remoting.Channel.call(Channel.java:993)
at hudson.Launcher$RemoteLauncher.kill(Launcher.java:1150)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:534)
at hudson.model.Run.execute(Run.java:1896)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
