See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4452/display/redirect?page=changes>
Changes:
[Udi Meiri] Release script fixes
------------------------------------------
[...truncated 24.60 MB...]
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 ToKeyedWorkItem (15/16)#0 3e4e1f7a40b6382f334a5ea51248b2e8.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (11/16)#0
27cb6e071353f3315ea37c7ea7b837a7.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (5/16)
(f7026658732c76dd966d4d8f0225645a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (2/16)#0 5878f09bf848a0be73739354e281be8e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (7/16) (7a21416725ebec8a4089b2482819900e) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (12/16)#0
eb01b1babd6bbbbf480d631ac73d05ca.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (13/16)
(d02300f1cd9f4333113c17add106b9a3) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (14/16)#0
4faf30e5cf5a7e0a1699ce9f8d3af23a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (13/16) (f409bf966510f07790941bae1fe82116) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (4/16)#0 47323f90d98398bd028cba618bbcd704.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (14/16)#0 3627c3b2c9dc945fc2b275aaaf0d1e93.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (3/16)
(3f259cb648fbb955826d9986631f3d2c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (16/16)#0 ca9bbaab1b678aa6882de52c1b289034.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (9/16) (2f6c4951ea9ec48a262586cebea801e3) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (1/16)#0 4f0915226ba599bcf5dce12ec0843b1b.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (11/16)#0 c1585bc3543a1c18a1fdc87ef20eb24e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (10/16)#0
0e1fc04cae27f306c2a75ba95ef18d87.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (15/16) (3e4e1f7a40b6382f334a5ea51248b2e8) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (11/16)
(27cb6e071353f3315ea37c7ea7b837a7) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (10/16)#0 65b8d8fbc8d00691c655b9e501f0afb9.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (2/16) (5878f09bf848a0be73739354e281be8e) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (16/16)#0
631cba9724ca0181458fad2926522be5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 [1]Read from
debezium/ExternalTransform(beam:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (1/16)#0
cbf49da408d2bed8f33f8677e2a2e0f0.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (12/16)
(eb01b1babd6bbbbf480d631ac73d05ca) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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 ToKeyedWorkItem (5/16)#0 457f8a7a87303b999bf3e60b1dc5196a.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (14/16)
(4faf30e5cf5a7e0a1699ce9f8d3af23a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (4/16) (47323f90d98398bd028cba618bbcd704) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (14/16) (3627c3b2c9dc945fc2b275aaaf0d1e93) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (16/16) (ca9bbaab1b678aa6882de52c1b289034) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (1/16) (4f0915226ba599bcf5dce12ec0843b1b) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (11/16) (c1585bc3543a1c18a1fdc87ef20eb24e) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (10/16)
(0e1fc04cae27f306c2a75ba95ef18d87) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (10/16) (65b8d8fbc8d00691c655b9e501f0afb9) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (16/16)
(631cba9724ca0181458fad2926522be5) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM 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:external:java:debezium:read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (1/16)
(cbf49da408d2bed8f33f8677e2a2e0f0) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (5/16) (457f8a7a87303b999bf3e60b1dc5196a) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Starting PostgresConnectorTask with configuration:'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
connector.class = io.debezium.connector.postgresql.PostgresConnector'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.dbname = inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.user = debezium'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.hostname = localhost'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.password = ********'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
beam.parent.instance = 29779206'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.server.name = dbserver1'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.history =
org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
include.schema.changes = false'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.include.list = inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.port = 39362'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:18 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
user 'debezium' connected to database 'inventory' on PostgreSQL 11.13 (Debian
11.13-1.pgdg90+1) on x86_64-pc-linux-gnu, compiled by gcc (Debian
6.3.0-18+deb9u1) 6.3.0 20170516, 64-bit with roles:"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 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:122 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:122 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:122 b"\trole
'debezium' [superuser: true, replication: true, inherit: true, create role:
true, create db: true, can log in: true]"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"\trole
'pg_monitor' [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:122 b"\trole
'pg_read_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:122 b"\trole
'pg_execute_server_program' [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:122 b"\trole
'pg_read_all_stats' [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:122 b"\trole
'pg_signal_backend' [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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Obtained valid replication slot ReplicationSlot [active=false,
latestFlushedLsn=null, catalogXmin=null]'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
No previous offset found'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Taking initial snapshot for new datasource'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Creating replication slot with command CREATE_REPLICATION_SLOT debezium
LOGICAL decoderbufs'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Requested thread factory for connector PostgresConnector, id = dbserver1 named
= change-event-source-coordinator'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw0] [32mPASSED[0m
apache_beam/io/gcp/bigquery_io_read_it_test.py::BigqueryIOReadIT::test_bigquery_read_custom_1M_python
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy
[gw0] [32mPASSED[0m
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch
[gw0] [32mPASSED[0m
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch_kms
[gw0] [32mPASSED[0m
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch_kms
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch_rewrite_token
[gw0] [33mSKIPPED[0m
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_batch_rewrite_token
apache_beam/io/gcp/gcsio_integration_test.py::GcsIOIntegrationTest::test_copy_kms
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Creating thread
debezium-postgresconnector-dbserver1-change-event-source-coordinator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Metrics registered'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Context created'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Taking initial snapshot for new datasource'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
According to the connector configuration data will be snapshotted'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 1 - Preparing'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Setting isolation level'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Opening transaction with statement SET TRANSACTION ISOLATION LEVEL
SERIALIZABLE, READ ONLY, DEFERRABLE;'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 2 - Determining captured tables'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122
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:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 3 - Locking captured tables'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
Waiting a maximum of '10' seconds for each table lock"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 4 - Determining snapshot offset'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Creating initial offset context'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
Read xlogStart at 'LSN{0/2078000}' from transaction '602'"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
Read xlogStart at 'LSN{0/2078000}' from transaction '602'"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 5 - Reading structure of captured tables'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b"INFO:
Reading structure of schema 'inventory'"
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:20 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Snapshot step 6 - Persisting schema history'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:20 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Creating thread
debezium-postgresconnector-dbserver1-change-event-source-coordinator'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Metrics registered'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Context created'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Taking initial snapshot for new datasource'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Oct 08,
2021 6:46:19 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
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]
