See
<https://ci-beam.apache.org/job/beam_PostCommit_Python_Examples_Flink/1000/display/redirect>
Changes:
------------------------------------------
[...truncated 51.14 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (3/16) (1cc45b614e4d8d5d407d89fe4254d9ac) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (4/16) (d6779a1fcd6a84660cdd99acc316dd28) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (5/16) (bcbbb68ffc266407fd01da301241a887) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (6/16) (0f2438fceab959cdb36da6f4a286ead5) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (7/16) (e84d70486c861ebc1e57ad8a2af64457) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (8/16) (e9ad9d0e2a1bada999a407628a505703) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (9/16) (69ab2b09d86b8ac989bfabdb7295ea32) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (10/16) (1b929cb72164708488327e77bab91593) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (11/16) (358d0d38bcca758f9c4d7d725841a763) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (12/16) (bf626c7d24230039fcaed475b21539da) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (13/16) (f3e0d99df31c1b0441add7a6fba6abe8) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (14/16) (1874bf89fc3bfe76d15d2ae44bd7f121) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (15/16) (691397e5091ee43133f1995018146cf4) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (16/16) (5c55782d235677413f40610e01d94d23) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (1/16) (a2b7cd1db05f75b5f9eff74b8e44976e) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (2/16) (8ec5e8570557577057228883739ade91) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (3/16) (a08a443bd7650e409a11b8fbe33ed271) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (4/16) (7775a21de165332f3287699546951f91) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (5/16) (911766989f9b35191f9784c3ae0251ca) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (6/16) (bad4d83d542e5c7e89bb17dc09d7ae3b) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (7/16) (9f83246fec52b89900ad3c8eb8df387d) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (8/16) (29a24e92736b49b1106e96b30686571b) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (9/16) (be356d61b873fcae2bdc6a488ea9cb41) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (10/16) (6d16da9fa7d74beef6948db9cdfcefb2) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (11/16) (d06d38f1b9bc995903afbc62473172ff) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (12/16) (4fd0740b201995b22f700d51e5a400f5) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (13/16) (12fc1f0919a24930d7999250a9a58f57) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (14/16) (05ded51dcc58914dad07632427c041cc) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (15/16) (aaac8072353527dc796f990f26d2191a) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [3]read_words/Read/{Map(<lambda at
iobase.py:908>), SDFBoundedSourceReader}) -> FlatMap (FlatMap at
ExtractOutput[0]) (16/16) (0093ab484f718761926cfe9b4fc6e194) switched from
CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(1/16) (cd143f5f669b409c670d7797c05e14d1) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(2/16) (0cf8579a380e95677b906564b000a29e) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(3/16) (0ed607e1d3ff6cc19ff08b6dad75d535) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(4/16) (b60b3f4b2114f4295d8937f63d85c4ae) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(5/16) (00932875210d8230a6deb516708b0db5) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(6/16) (2626ac340e258e492e8e4603f6dcbf7c) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(7/16) (6a0ffa72a955d1e35fea34981d14b4f3) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(8/16) (0d333d557629e6b9790ab30c28c5cd36) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(9/16) (214cda9b9b31f66873649602bf78b747) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(10/16) (6387e74df3274f4139832acc3bfd44fc) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(11/16) (b195b194e404f2609e92ade73489793a) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(12/16) (3b9984e77bd26efdeb3d25c685fec563) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(13/16) (c4ca0c665ff09f01e333a5d941412a0c) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(14/16) (36dbf788609d18dc73da3dc40e132ef3) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(15/16) (875fc4fa285a6a95d72d18f266a4e630) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at [2]read_words/{Read, _PassThroughThenCleanup})
(16/16) (9c76d7c103387222b259924f57336ea9) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (1/16) (0de23aa22dd966f96dee404fc0f9a9cb)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (2/16) (82afb5c464c568e6d2313d37068a1876)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (3/16) (18f01a928367a81f755c2f943cb51338)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (4/16) (f62be9e6342d7a952771d70dad9dd1bd)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (5/16) (72f9b862e1f0f28ca85921628ed3f586)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (6/16) (8c6bf521fb5dca6d45260bac166e8bd9)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (7/16) (8941f68ff498b9dba938d3e4a980baf8)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (8/16) (59227195675e880333603ead2f0f8e95)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (9/16) (cfe3bef8ef516f386eb3f548d9339784)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (10/16)
(d04893036c80a5be26a83fee198852b2) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (11/16)
(f6de0b61ca9f1fe5ae2ca03f51b68b55) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (12/16)
(b9123751351bdf59debb1013f4062c64) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (13/16)
(f4687df5409f63b89655e87bb5b7354a) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (14/16)
(f82387095e971065deceb504a4a8c5d5) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (15/16)
(6f1289bc50b09b9bbd90773a0ed07574) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[1]) (16/16)
(a1aa25d905b4dac405cc1e6c537369a1) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (1/16)
(206f2b27a052800b7f8e37b4bf35df9c) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (2/16)
(763bf313885e9d30a9311a39442d1d59) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (3/16)
(5f4f308c8919ff9a260f13af316afdba) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (4/16)
(a79d5a2eb067b9b2398c591f71398c00) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (5/16)
(1ecc12a304d26d6e20c8bfec6db0627f) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (6/16)
(84d1334530032c2ba3c583149fb4c091) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (7/16)
(55a55d06f225ffbf40cb98b748108bcc) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (8/16)
(77143393f5e570ce16a35bd5a45bb077) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (9/16)
(efb2a6b85d679e5c63f68e5b8d369539) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (10/16)
(8ba5edfde44cbaa49041f761380b9613) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (11/16)
(216c1a99925801273d4c21ac6f78ba8f) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (12/16)
(a0816388e3697a079b6afe7909e21b39) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (13/16)
(33cb8ff5bd001e94ef3a707c78c0aa4e) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (14/16)
(2c6723df1ce13327f1020324b44853b3) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (15/16)
(a50832f7c8faea2efd285225713ba828) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
MapPartition (MapPartition at
[1]read_words/_PassThroughThenCleanup/ParDo(RemoveExtractedFiles)) (16/16)
(84dafdcf6b65a48845f6e530d97287bd) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (1/16) (c8eebd2fffc86313b1d98405fdfc7f84) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (2/16) (76f73fc9ae9a3d826a7046abf31ece87) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (3/16) (e9d83e11a003f273787be5fe35f945fc) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (4/16) (02378865c0c1e4c003201068509c78b7) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (5/16) (4981737648981a14ce6fc6f20f0eeddf) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (6/16) (069d26df40ef0ec191f4067e55664ae4) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (7/16) (4744b2179c4972d1641d414d4ff4a8b0) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (8/16) (c1cf0b9141b0245a37946cc749d9881c) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (9/16) (5f785e18f332fb16bb68a77aa74919a5) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (10/16) (0917487f317239329362bb62f6d3cc5e) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (11/16) (adf3f37c490db5661298006ca3235828) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (12/16) (486021cfff1412456bea6335d441b721) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (13/16) (1bfd9ea9d85d96d6b2bb941787d1c25a) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (14/16) (7092ae4b92637c6255f5a265c9e865cc) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (15/16) (682264edfbddc58fc8eb87f56fb09f8b) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
DataSink (DiscardingOutput) (16/16) (29f907e32d7ef2ad64b868df60f3be3b) switched
from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (1/16) (c4badcfa00c6274fc9ec8b82b14292c3)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (2/16) (d1860c263155951d09c34ccecc138941)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (3/16) (e01e77608dc43fe9000d94c143f4dd3d)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (4/16) (0224accc0cbf6effafb08f2a5b315d20)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (5/16) (c7c7571a23c15fc04b50acb3bf3970e6)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (6/16) (ad70d02ed2e80d7146bd3026c7095812)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (7/16) (3de8ba0306d022504c30cbe69ae0d2e2)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (8/16) (117bc1cc130565e8eec013c0402faac4)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (9/16) (c739f15b8edb3ca62996c6e58addce08)
switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(2b7e32c710950cab26313636544cf2d6) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(ecf7ea4878ef9be2e2cf4ac22bdcf561) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(a199ca646899bb556a32f08b8b9b655c) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(ed5f4650533bd3bca693e98fb959f6ad) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(800c468e85932757ffcf4d0717eec960) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (15/16)
(5b2103de871edcfdf87936ea311cbcdd) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
FlatMap (FlatMap at ExtractOutput[0]) (16/16)
(90762c55012a2873b2db6bb40dd1425d) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (1/16)
(fa93b6c5d5e024018653f46c1b48629a) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (2/16)
(8417086937cb2f42b332f6e2677eeac5) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (3/16)
(81a350ba55eae73c6f674e382965f4bd) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (4/16)
(a4213f9fdfa90baf5d3da7a280ca3e7d) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (5/16)
(bdc179d11fa6e5b1676e2773021504d5) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (6/16)
(3d876f7569e2037aa6f0da4fd233555c) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (7/16)
(09587908e2485d7c8fd176c4da4c0ba4) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (8/16)
(87e55e8651c138b71ebf330270bbedaf) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (9/16)
(e882acc08a315a4a199db2dcf0529ba2) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (10/16)
(59667d154356604ce628521a3f4246b8) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (11/16)
(1b08933dfbbe53dcc3094eea97df6379) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (12/16)
(93cbf5872fddc876d5da98b8cd6ccb2a) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (13/16)
(6fe76327a6981c880b9e47244a040087) switched from CREATED to SCHEDULED.
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 Oct 16,
2022 9:44:03 AM org.apache.flink.runtime.executiongraph.Execution
transitionState
INFO apache_beam.utils.subprocess_server:subprocess_server.py:126 INFO:
CHAIN MapPartition (MapPartition at [2]create_ignore_word/{FlatMap(<lambda at
core.py:3481>), Map(decode)}) -> FlatMap (FlatMap at ExtractOutput[0]) (14/16)
(d8f44ce8fbb2af440598fd4797708baf) switched from CREATED to SCHEDULED.
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]
