See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4747/display/redirect?page=changes>
Changes:
[stranniknm] [BEAM-13466]: sort categories and examples by name
[noreply] [BEAM-13399] Add check for dev versions of JARs to download code
[noreply] Merge pull request #16122 from [BEAM-13345] [Playground] add resizable
[noreply] Merge pull request #16170 from [BEAM-13411][Playground] Add getting of
[noreply] Merge pull request #16172 from [BEAM-13417] [Playground] Add java
[noreply] Merge pull request #16240 from [BEAM-13465][Playground] Change error
[noreply] Merge pull request #16234 from [BEAM-13461][Playground] [Bugfix] Error
[noreply] Merge pull request #15489 from [BEAM-12865] Allow custom
batch_duration
[noreply] [BEAM-13483] Increase timeout of Java Examples Dataflow suite.
(#16226)
[noreply] Pin transitive log4j dependencies to 2.17.0 in :sdks:java:io:hcatalog
------------------------------------------
[...truncated 34.53 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Un-registering task and sending final execution state FINISHED to JobManager
for task [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
d1290470f56dc14ffa97f5e1aaaf6774.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (2/16) (053cc70bd6b4f101ea244432e8bff77c) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
44a57f54b09282801bdbcfaa2de6e17c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (13/16)#0 4b977a4a4739e1dd06d1bf1cd2de521d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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} (5/16)
(8c9a634b27d323ae9a95d02525cde136) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (15/16)#0 b5c749abbb5dac7cd6bd1b4c4324510b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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,
ParDo(KafkaSourceConsumer)} (3/16)#0 f9e5dc35afb52606562a47676ad7a160.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (4/16) (b52ad75f9410491ff2eae949af9f5da3) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (14/16)#0 a8d9340c56494527588704a380783617.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
d5e98a3f074e996c7998ef926c8fc92f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (12/16)#0 440d15663327059f3bbfeae6d1f7dac0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
e1cdedf5a07f2b971774586885a25c45.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (7/16)#0 c83ee87438093cb0d62271b41734090e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
26e8ec362db6a35dfe2f4c987c03736f.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
fede156c081bf1350860e6a68e4cfd0d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (8/16)#0 441a2b0d75ab8ec0d8dbe76a069a94b4.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(2136ea73773b0ca234b881c2b7d8b85a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.taskmanager.Task transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (10/16)#0 (a0bd6ea07c39d0ff50b2a94232fe6c83) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for ToKeyedWorkItem (10/16)#0
(a0bd6ea07c39d0ff50b2a94232fe6c83).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (5/16) (0506f0eb37595e3fe9949321a9253f90) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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} (10/16)#0
(aa1d383b9bf6c890c099005977d4f315) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(4e41a1199b3f0fd37780d4fee0bd6386) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(d1290470f56dc14ffa97f5e1aaaf6774) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(44a57f54b09282801bdbcfaa2de6e17c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (13/16) (4b977a4a4739e1dd06d1bf1cd2de521d) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (15/16) (b5c749abbb5dac7cd6bd1b4c4324510b) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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) (f9e5dc35afb52606562a47676ad7a160) switched
from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
24cacd902f80656c27db99c66bace3d0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.taskmanager.Task doRun'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Freeing task resources for [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
(aa1d383b9bf6c890c099005977d4f315).'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (6/16)#0 abf7d9cf0c605fa0ff25c70e73f9218b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
f9596856f172607b01292b459ce48361.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
0b6ec5486b4f3e35f201c9a38ed63b12.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (9/16)#0 1dcc0f2e7753eb0ef8a067e9bc1bc7db.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (3/16)#0 97a1d8432552e0f098c4d41c7228f600.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (11/16)#0 93f31577a1afb8ab233a9e0cbc682f7c.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 ToKeyedWorkItem (10/16)#0 a0bd6ea07c39d0ff50b2a94232fe6c83.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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 [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
aa1d383b9bf6c890c099005977d4f315.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (14/16) (a8d9340c56494527588704a380783617) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(d5e98a3f074e996c7998ef926c8fc92f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (12/16) (440d15663327059f3bbfeae6d1f7dac0) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(e1cdedf5a07f2b971774586885a25c45) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (7/16) (c83ee87438093cb0d62271b41734090e) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(26e8ec362db6a35dfe2f4c987c03736f) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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} (6/16)
(fede156c081bf1350860e6a68e4cfd0d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (8/16) (441a2b0d75ab8ec0d8dbe76a069a94b4) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(24cacd902f80656c27db99c66bace3d0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (6/16) (abf7d9cf0c605fa0ff25c70e73f9218b) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(f9596856f172607b01292b459ce48361) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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} (3/16)
(0b6ec5486b4f3e35f201c9a38ed63b12) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (9/16) (1dcc0f2e7753eb0ef8a067e9bc1bc7db) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (3/16) (97a1d8432552e0f098c4d41c7228f600) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (11/16) (93f31577a1afb8ab233a9e0cbc682f7c) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
ToKeyedWorkItem (10/16) (a0bd6ea07c39d0ff50b2a94232fe6c83) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 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)
(aa1d383b9bf6c890c099005977d4f315) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
Starting PostgresConnectorTask with configuration:'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
connector.class = io.debezium.connector.postgresql.PostgresConnector'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.dbname = inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.user = debezium'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.hostname = localhost'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.password = ********'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
beam.parent.instance = 2117363672'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.server.name = dbserver1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.history =
org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
include.schema.changes = false'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.include.list = inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'INFO:
database.port = 45577'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:11 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw7] [32mPASSED[0m
apache_beam/examples/complete/game/leader_board_it_test.py::LeaderBoardIT::test_leader_board_it
apache_beam/io/parquetio_it_test.py::TestParquetIT::test_parquetio_it
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
user 'debezium' connected to database 'inventory' on PostgreSQL 14.1 (Debian
14.1-1.pgdg110+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 10.2.1-6)
10.2.1 20210110, 64-bit with roles:"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_read_all_settings' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_database_owner' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_read_all_data' [superuser: false, replication: false, inherit: true, create
role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_write_all_data' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_write_server_files' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'debezium' [superuser: true, replication: true, inherit: true, create role:
true, create db: true, can log in: true]"
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.blacklist" is deprecated and
will be removed in future versions. Please use "schema.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.blacklist" is deprecated and
will be removed in future versions. Please use "table.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "table.whitelist" is deprecated and
will be removed in future versions. Please use "table.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "schema.whitelist" is deprecated and
will be removed in future versions. Please use "schema.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.whitelist" is deprecated and
will be removed in future versions. Please use "column.include.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125
b'WARNING: Using configuration property "column.blacklist" is deprecated and
will be removed in future versions. Please use "column.exclude.list" instead.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b'Dec 21,
2021 12:21:12 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"INFO:
user 'debezium' connected to database 'inventory' on PostgreSQL 14.1 (Debian
14.1-1.pgdg110+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian 10.2.1-6)
10.2.1 20210110, 64-bit with roles:"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_read_all_settings' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_database_owner' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_read_all_data' [superuser: false, replication: false, inherit: true, create
role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_stat_scan_tables' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_write_all_data' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:125 b"\trole
'pg_write_server_files' [superuser: false, replication: false, inherit: true,
create role: false, create db: false, can log in: false]"
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]
