See
<https://ci-beam.apache.org/job/beam_PostCommit_Python37/4520/display/redirect?page=changes>
Changes:
[noreply] [BEAM-13226] Batch metrics parsing errors (#15972)
[noreply] [BEAM-13239] pass through io.EOF when decoding row (#15971)
[noreply] [BEAM-5378] Register types & funcs for examples. (#15970)
------------------------------------------
[...truncated 47.32 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (12/16) (89d832a5566188cfbe2f48f7135c5267)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (1/16) (bf986575a985429bdde54c83395387cf)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (7/16) (7c46d37bc5abe0524c4d1c0d74bfcb96)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (5/16)#0 (d05062e35d891a2752e14038f49d4ce4)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Freeing task resources for [4]assert_that/{Create, Group} (5/16)#0
(d05062e35d891a2752e14038f49d4ce4).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [4]assert_that/{Create, Group} (5/16)#0
d05062e35d891a2752e14038f49d4ce4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:45 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[4]assert_that/{Create, Group} (5/16) (d05062e35d891a2752e14038f49d4ce4)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:42:55 PM
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory
createEnvironment'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Still waiting for startup of environment apache/beam_java8_sdk:2.35.0.dev for
worker id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:00 PM
org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory
createEnvironment'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Still waiting for startup of environment apache/beam_java8_sdk:2.35.0.dev for
worker id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
control'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Control client connected with id 1-1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.beam.runners.fnexecution.logging.GrpcLoggingService
logging'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Beam Fn Logging client connected.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (fbe49ad3a504eb7a618de29be8abef78)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (fbe49ad3a504eb7a618de29be8abef78)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Fn Harness started'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Entering instruction processing loop'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(053f43baf1adeec3e891467a76b2202a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(053f43baf1adeec3e891467a76b2202a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (16/16)#0 (30fe2753991878b216efe65f9ae66b8c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (16/16) (30fe2753991878b216efe65f9ae66b8c)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(da5310ac91952ae2495e2e9e60a16cfb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(da5310ac91952ae2495e2e9e60a16cfb) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (12/16)#0 (e7484b8ff7ee51cee595bab21e528b93)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(1a032448a7b137ba23fcbf8522ace952) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (12/16) (e7484b8ff7ee51cee595bab21e528b93)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(1a032448a7b137ba23fcbf8522ace952) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(5c526411b991efa7499293f252f7a627) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(5c526411b991efa7499293f252f7a627) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (5/16)#0
(92089115d5b0d4f1b704389b7c6a3444) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(31d8c292dc775694928215b7ed4c4441) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (5/16)
(92089115d5b0d4f1b704389b7c6a3444) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(31d8c292dc775694928215b7ed4c4441) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (7/16)#0 (7056df01267d7e7c951310ab3734189d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(3e3dbbf1db4535b204cead4a79188e9f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (7/16) (7056df01267d7e7c951310ab3734189d) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(3e3dbbf1db4535b204cead4a79188e9f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (2dc7b60dc9823955848eddf2d17aafef)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (2dc7b60dc9823955848eddf2d17aafef)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (3/16)#0 (24bb74d3d55b13689a124a41dc91c3ec)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (3/16) (24bb74d3d55b13689a124a41dc91c3ec) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (8a3241073be6d5c47644d89d9f0dea15)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (8a3241073be6d5c47644d89d9f0dea15)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (10/16)#0 (fbda437a5750402ff96e3238d939a092)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (5/16)#0 (9681fdf85b80b3d9c394bf5cffef1a8d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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
(996bdeea6f78da165d5485f8c8175b9f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (6/16)#0
(c8b5bb6dfa65ab5d2eb345a1cbf1b5e9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(15590e13824493a18545aa408270b288) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(c79f6f927862820458da53ea43673e13) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(8b50552d8ee7d62bf4e47018c86d0447) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0
(b319dae88aa0ac51da8e67b5b43afc30) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (1/16)#0 (46507acdedaf2cd8ec6395a30d19cdc8)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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
(ea6489386001f223b230f1ec8231312b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (c35ebcaa100932f9ff6203c463e67acd)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (8/16)#0 (089b0fb542a62924bb37c6e6924bb1a6)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0 (c27dc04d93b4770eb5b8772598d6b963)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (f5a042474f50484bbd961953ba1d3410)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (3/16)#0
(b4448f037913bf21aceacf3db51d00be) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (13/16)#0 (8f4575449cd327e50251abe3b9777930)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (3d859a82e4fc9d7f1559eb011be1d653)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (11/16)#0 (009fcd5e9e7490d65a847de4864d4915)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (39821f85b997e7ca1dc8c1a7b050be68)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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
(3a8a00d6fa3eef81110c184e2463bd2a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (15/16)#0 (b5e83f32951df8d75de0f73c14f9a51d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (10/16) (fbda437a5750402ff96e3238d939a092)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (5/16) (9681fdf85b80b3d9c394bf5cffef1a8d) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(996bdeea6f78da165d5485f8c8175b9f) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (6/16)
(c8b5bb6dfa65ab5d2eb345a1cbf1b5e9) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(15590e13824493a18545aa408270b288) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(c79f6f927862820458da53ea43673e13) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(8b50552d8ee7d62bf4e47018c86d0447) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(b319dae88aa0ac51da8e67b5b43afc30) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (1/16) (46507acdedaf2cd8ec6395a30d19cdc8) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (6/16)#0 (16e5e0492ef6a013c37d758009f11986)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(ea6489386001f223b230f1ec8231312b) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (c35ebcaa100932f9ff6203c463e67acd)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (8/16) (089b0fb542a62924bb37c6e6924bb1a6) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (c27dc04d93b4770eb5b8772598d6b963)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (f5a042474f50484bbd961953ba1d3410)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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} (3/16)
(b4448f037913bf21aceacf3db51d00be) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (13/16) (8f4575449cd327e50251abe3b9777930)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (3d859a82e4fc9d7f1559eb011be1d653)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (11/16) (009fcd5e9e7490d65a847de4864d4915)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (39821f85b997e7ca1dc8c1a7b050be68)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)
(3a8a00d6fa3eef81110c184e2463bd2a) switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (15/16) (b5e83f32951df8d75de0f73c14f9a51d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (6/16) (16e5e0492ef6a013c37d758009f11986) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (9/16)#0 (8a0e76e8eede8fc7b6d9fd39722a07cd)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (9/16) (8a0e76e8eede8fc7b6d9fd39722a07cd) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/16)#0 (c5f350ca07880fcc23b1324d7527d309)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
> Task :sdks:python:test-suites:dataflow:py37:postCommitIT
[gw1] [32mPASSED[0m
apache_beam/io/gcp/bigquery_io_read_it_test.py::BigqueryIOReadIT::test_bigquery_read_custom_1M_python
apache_beam/io/gcp/pubsub_integration_test.py::PubSubIntegrationTest::test_streaming_data_only
> Task :sdks:python:test-suites:portable:py37:postCommitPy37IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/16) (c5f350ca07880fcc23b1324d7527d309)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (be88d087da54c5a85fdfa311056fef3a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (be88d087da54c5a85fdfa311056fef3a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (4/16)#0 (4eede53050256b434ce1bde152c8fa6d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (109c377c513abbdc0e4fc62242c0544a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (4/16) (4eede53050256b434ce1bde152c8fa6d) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (109c377c513abbdc0e4fc62242c0544a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16)#0 (81ce93d912521b5f878224771b606199)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16) (81ce93d912521b5f878224771b606199) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (3d65fe6d39f327060c85ba7ef9f65ff9)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (3d65fe6d39f327060c85ba7ef9f65ff9)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (fbe49ad3a504eb7a618de29be8abef78)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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
(fbe49ad3a504eb7a618de29be8abef78).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskexecutor.TaskExecutor
unregisterTaskAndNotifyFinalState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 fbe49ad3a504eb7a618de29be8abef78.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (fbe49ad3a504eb7a618de29be8abef78)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (26020facdb542a2c633f79bd8d966b77)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (26020facdb542a2c633f79bd8d966b77)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)#0 (c27dc04d93b4770eb5b8772598d6b963)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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)} (2/16)#0 (c27dc04d93b4770eb5b8772598d6b963).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:04 PM org.apache.flink.runtime.taskmanager.Task transitionState'
> Task :sdks:python:test-suites:portable:py37:postCommitPy37IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/Create.Values/Read(CreateSource)/{ParDo(OutputSingleSource),
ParDo(BoundedSourceAsSDFWrapper)} (1/16) (c5f350ca07880fcc23b1324d7527d309)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (be88d087da54c5a85fdfa311056fef3a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (be88d087da54c5a85fdfa311056fef3a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (4/16)#0 (4eede53050256b434ce1bde152c8fa6d)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (109c377c513abbdc0e4fc62242c0544a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (4/16) (4eede53050256b434ce1bde152c8fa6d) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (109c377c513abbdc0e4fc62242c0544a)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16)#0 (81ce93d912521b5f878224771b606199)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[3]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/{Create.Values,
ParDo(KafkaSourceConsumer)} (2/16) (81ce93d912521b5f878224771b606199) switched
from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (3d65fe6d39f327060c85ba7ef9f65ff9)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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) (3d65fe6d39f327060c85ba7ef9f65ff9)
switched from INITIALIZING to RUNNING.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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 (fbe49ad3a504eb7a618de29be8abef78)
switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 15,
2021 6:43:03 PM org.apache.flink.runtime.taskmanager.Task doRun'
java.lang.OutOfMemoryError: GC overhead limit exceeded
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
