See
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/31/display/redirect?page=changes>
Changes:
[Pablo Estrada] Simplify README for new users
[laraschmidt] Fix final allowskew error to properly handle a large allowedSkew
[noreply] [BEAM-13946] Add get_dummies(), a non-deferred column operation on
------------------------------------------
[...truncated 34.78 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (1/16)
(bf1f66e32cd5030f6996fabfbe40e34a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (13/16) (be9f85ae1349adf2abb0789663df7f96)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (7/16)
(37594d31eb0ac53202c7856a3fb99aa1) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (11/16) (f554bf9df8f5d6f309f9165d81234bf6)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (8/16)
(94e775e42f021b33d922abdafeb5e97b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (16/16)#0
(5359946eaab44f0e91eea0b6ca1608b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (12/16)
(d294f01c90ad846b6f304c9bb48ea839) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (14/16)#0 (58387a311da8da69b59c28a3db9487c5)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (15/16)#0 (17fbdfa79957ba9302b7f8ed36a086d8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (10/16) (21a44cebba979f4b8494e4c41634f836)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (13/16)
(16a477a5e9f47198fc7a58b489ca6771) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (6/16) (608af0ba88e334ca7044ba80b232fe28)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (11/16)
(323ebbce21c0afa685ec59693a73524a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (7/16) (b7d7b812a14d24c155c938da69f43243)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (9/16) (5e2ee34e1a36635a2bd9744a45454a11) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (8/16) (dca26dc80bec692bedf34fa384990288) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (7/16) (07572964ee9c17fcc8625c9af2c75f60) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (9/16)
(b82095c90b56ef0cbd69ed7d58e79be7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (9/16) (7a80ff75bf9a7eab08631c8c52698ea7)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (3/16) (f51c63cd11ae8a19e00007224781b53e)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (15/16)
(9ccb2daa8f3d0e5e918589f9ca2ae883) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (16/16) (c83358639b6ab63f65fd9af6da7fb2d8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (14/16)
(a03ab548412f7c246f58487f44b1c5eb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (10/16)
(dd8037ab7e4b66c36448a2799aba0d06) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (13/16) (763b1fb15b9e59bc6f1234036681ee85)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0 (f554bf9df8f5d6f309f9165d81234bf6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0
(f554bf9df8f5d6f309f9165d81234bf6).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 (4535fc9c5ab8ee82c437340d9ec67fbe)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (11/16)#0 f554bf9df8f5d6f309f9165d81234bf6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16)#0 (f784ccb949b56ceac721d4715e38b34c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (6/16)#0 (c5d0d670181c262c44d7f80d458b69e6)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0 (684d9449b391f08777157549d89eeb44)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (11/16)#0 (c49319cfe367acc7bd86867518955f46)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (2/16)#0
(e1f13384a709a3e69d14eefa693ab65c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 (57ec2100f6382ba4d004b923f44d8f1f)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (3/16)#0 (7126491171ed990078dc3981e0eeee0c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (12/16)#0 (cb26a993d355d4c2d0380b39aba26a63)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (4/16)#0
(0815d31cb013a524825666c8cde209d3) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (1/16)#0 (2355f661c8fe5466ab39512fce789572)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 (e79462c08023eae3b3e23c8d15e65a71)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0 (be9f85ae1349adf2abb0789663df7f96)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0
(be9f85ae1349adf2abb0789663df7f96).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (13/16)#0 be9f85ae1349adf2abb0789663df7f96.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (2/16) (737ca6e424de02b3108f07d08dbe6c0c)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 (f51c63cd11ae8a19e00007224781b53e)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 (f51c63cd11ae8a19e00007224781b53e).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (16/16)
(5359946eaab44f0e91eea0b6ca1608b7) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (3/16)#0 f51c63cd11ae8a19e00007224781b53e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 (7a80ff75bf9a7eab08631c8c52698ea7)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (14/16) (58387a311da8da69b59c28a3db9487c5)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 (7a80ff75bf9a7eab08631c8c52698ea7).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0
(684d9449b391f08777157549d89eeb44).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (9/16)#0 7a80ff75bf9a7eab08631c8c52698ea7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (15/16) (17fbdfa79957ba9302b7f8ed36a086d8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0 (90c6afc2afcfc4baa7eee2985d0d0c56)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0
(90c6afc2afcfc4baa7eee2985d0d0c56).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 (b9fa1be8bc33a0ef47f4ff796ffc3a42)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 (608af0ba88e334ca7044ba80b232fe28)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16) (4535fc9c5ab8ee82c437340d9ec67fbe)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 (ed46a5c3bbe2c740e14cc194f3ffe069)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0
(b9fa1be8bc33a0ef47f4ff796ffc3a42).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 (aed05c388a847e9fa9abce17ff28d706)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 (aed05c388a847e9fa9abce17ff28d706).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 (608af0ba88e334ca7044ba80b232fe28).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 (ed46a5c3bbe2c740e14cc194f3ffe069).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (11/16) (c49319cfe367acc7bd86867518955f46)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (3/16) (7126491171ed990078dc3981e0eeee0c) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (12/16) (cb26a993d355d4c2d0380b39aba26a63)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16) (57ec2100f6382ba4d004b923f44d8f1f)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (4/16)
(0815d31cb013a524825666c8cde209d3) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (1/16) (2355f661c8fe5466ab39512fce789572) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (2/16)
(e1f13384a709a3e69d14eefa693ab65c) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16) (e79462c08023eae3b3e23c8d15e65a71)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (6/16) (c5d0d670181c262c44d7f80d458b69e6) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (11/16) (f554bf9df8f5d6f309f9165d81234bf6)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16) (f784ccb949b56ceac721d4715e38b34c) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (13/16) (be9f85ae1349adf2abb0789663df7f96)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (3/16) (f51c63cd11ae8a19e00007224781b53e)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (9/16) (7a80ff75bf9a7eab08631c8c52698ea7)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (12/16)#0 684d9449b391f08777157549d89eeb44.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (4/16)#0 aed05c388a847e9fa9abce17ff28d706.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (6/16)#0 608af0ba88e334ca7044ba80b232fe28.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 (b7d7b812a14d24c155c938da69f43243)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (12/16) (684d9449b391f08777157549d89eeb44)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 (b7d7b812a14d24c155c938da69f43243).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 (57ec2100f6382ba4d004b923f44d8f1f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 (4535fc9c5ab8ee82c437340d9ec67fbe)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0
(57ec2100f6382ba4d004b923f44d8f1f).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 (4535fc9c5ab8ee82c437340d9ec67fbe).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (10/16)#0 90c6afc2afcfc4baa7eee2985d0d0c56.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 (e79462c08023eae3b3e23c8d15e65a71)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0
(e79462c08023eae3b3e23c8d15e65a71).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (16/16)#0 b9fa1be8bc33a0ef47f4ff796ffc3a42.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (4/16) (aed05c388a847e9fa9abce17ff28d706)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (5/16)#0 ed46a5c3bbe2c740e14cc194f3ffe069.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (7/16)#0 b7d7b812a14d24c155c938da69f43243.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16)#0 4535fc9c5ab8ee82c437340d9ec67fbe.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (6/16) (608af0ba88e334ca7044ba80b232fe28)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16)#0 57ec2100f6382ba4d004b923f44d8f1f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16)#0 e79462c08023eae3b3e23c8d15e65a71.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (10/16) (90c6afc2afcfc4baa7eee2985d0d0c56)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
getProcessBundleDescriptor request with id 1-69'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (16/16) (b9fa1be8bc33a0ef47f4ff796ffc3a42)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (5/16) (ed46a5c3bbe2c740e14cc194f3ffe069)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (7/16) (b7d7b812a14d24c155c938da69f43243)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (8/16) (4535fc9c5ab8ee82c437340d9ec67fbe)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (14/16) (57ec2100f6382ba4d004b923f44d8f1f)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Feb 18,
2022 12:26:27 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (15/16) (e79462c08023eae3b3e23c8d15e65a71)
switched from RUNNING to FINISHED.'
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-5' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:216)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:286)
at com.sun.proxy.$Proxy126.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1213)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1205)
at hudson.Launcher$ProcStarter.join(Launcher.java:522)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:317)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:806)
at hudson.model.Build$BuildExecution.build(Build.java:198)
at hudson.model.Build$BuildExecution.doRun(Build.java:163)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:514)
at hudson.model.Run.execute(Run.java:1888)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:43)
at hudson.model.ResourceController.execute(ResourceController.java:99)
at hudson.model.Executor.run(Executor.java:432)
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.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2799)
at
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:3274)
at
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:934)
at java.io.ObjectInputStream.<init>(ObjectInputStream.java:396)
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
ERROR: apache-beam-jenkins-5 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
