See
<https://ci-beam.apache.org/job/beam_PostCommit_Python36/4651/display/redirect>
Changes:
------------------------------------------
[...truncated 11.67 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
[1]Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (2/16)
(f9f2371a1ba8a3c443f489810a9c33f4) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (9/16)#0 d5aeb99ad8bd36d7c1c86f23b35bdb92.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 ca8375700c295f660a9ec3d6b8add815.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 8d38b4af75fc6542a2dd4e34b3202e71.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 feb2bf3e21d88cabfb2bfb12f45963ac.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (13/16)#0 48f2910ec7659f82ac3b2165531528c5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (12/16)#0 b286462fec7d9616713cc8eb0b7d8525.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (13/16)#0
62a597d9b7b4e21728786863d1fd9c4d.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (8/16)#0 d5d0ac2ff7225de8ed18b12b624155c6.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 370c78f54ceb679bdaf2f308bad87b0e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (7/16)#0 68778e19ae0c1f1b5651eee9d7677c10.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (3/16)#0 0e992cf6c9392cb89a6f29e6ceccbad5.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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 (15/16)#0 acd39710c73ffc6f718cdc2cc9c9f03e.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (12/16)
(3736a9666ae991d7e2682a07d2449c3e) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (3/16)
(ef7487aef2fc5ad4dbd424f628120794) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (15/16)
(e66c17b087585b20e98d74b18c82029c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (10/16)
(fabf1bb0e0ead0d7610515b7e0c11f6d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (1/16)
(60270084f06b813e79e715a0dcddc849) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (7/16)
(390d56083ec24131aef5ca9e170e9d0c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (4/16)
(246a1c3c4a122a34272647b966179359) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (9/16)
(959382cc963ff2df6902747b286b942a) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (8/16)
(91e2dea2a9078e393eb670660e589d3c) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (9/16) (d5aeb99ad8bd36d7c1c86f23b35bdb92) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (10/16) (ca8375700c295f660a9ec3d6b8add815) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (2/16) (8d38b4af75fc6542a2dd4e34b3202e71) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (1/16) (feb2bf3e21d88cabfb2bfb12f45963ac) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (13/16) (48f2910ec7659f82ac3b2165531528c5) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (12/16) (b286462fec7d9616713cc8eb0b7d8525) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0
-> [5]{Read from debezium, assert_that} (13/16)
(62a597d9b7b4e21728786863d1fd9c4d) switched from RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (8/16) (d5d0ac2ff7225de8ed18b12b624155c6) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (4/16) (370c78f54ceb679bdaf2f308bad87b0e) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (7/16) (68778e19ae0c1f1b5651eee9d7677c10) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (3/16) (0e992cf6c9392cb89a6f29e6ceccbad5) switched from RUNNING
to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 AM org.apache.flink.runtime.executiongraph.Execution
transitionState'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
ToKeyedWorkItem (15/16) (acd39710c73ffc6f718cdc2cc9c9f03e) switched from
RUNNING to FINISHED.'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
beam.parent.instance = 324575553'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
database.port = 33540'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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.'
> Task :sdks:python:test-suites:dataflow:py36:postCommitIT
[gw6] [32mPASSED[0m
apache_beam/examples/complete/game/hourly_team_score_it_test.py::HourlyTeamScoreIT::test_hourly_team_score_it
apache_beam/io/fileio_test.py::MatchIntegrationTest::test_transform_on_gcs
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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.14 (Debian
11.14-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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:41 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'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:41 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'Nov 27,
2021 12:27:41 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'INFO:
Metrics registered'
> Task :sdks:python:test-suites:portable:py36:postCommitPy36IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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.14 (Debian
11.14-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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:40 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'Nov 27,
2021 12:27:41 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'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:122 b'Nov 27,
2021 12:27:41 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'Nov 27,
2021 12:27:41 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter
log'java.lang.OutOfMemoryError: GC overhead limit exceeded
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'Nov 27,
2021 12:27:41 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'Nov 27,
2021 12:27:41 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'Nov 27,
2021 12:27:41 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'Nov 27,
2021 12:27:41 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log'
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]
