See
<https://ci-beam.apache.org/job/beam_PostCommit_Python39/2782/display/redirect>
Changes:
------------------------------------------
[...truncated 11.72 MB...]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Reading structure of schema 'inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 6 - Persisting schema history
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 7 - Snapshotting data
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Exporting data from table 'inventory.customers'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
For table 'inventory.customers' using select statement: 'SELECT * FROM
"inventory"."customers"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Stopping down connector
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING:
Snapshot was interrupted before completion
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot - Final stage
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Starting PostgresConnectorTask with configuration:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
connector.class = io.debezium.connector.postgresql.PostgresConnector
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.dbname = inventory
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.user = debezium
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.hostname = localhost
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.password = ********
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
beam.parent.instance = 1480178092
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.server.name = dbserver1
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.history =
org.apache.beam.io.debezium.KafkaSourceConsumerFn$DebeziumSDFDatabaseHistory
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
include.schema.changes = false
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.include.list = inventory
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
database.port = 35327
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
user 'debezium' connected to database 'inventory' on PostgreSQL 14.10 (Debian
14.10-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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 role
'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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Obtained valid replication slot ReplicationSlot [active=false,
latestFlushedLsn=LSN{0/2345EA0}, catalogXmin=765]
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO: No
previous offset found
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Taking initial snapshot for new datasource
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Requested thread factory for connector PostgresConnector, id = dbserver1 named
= change-event-source-coordinator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Creating thread
debezium-postgresconnector-dbserver1-change-event-source-coordinator
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Metrics registered
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Context created
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Taking initial snapshot for new datasource
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
According to the connector configuration data will be snapshotted
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 1 - Preparing
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 2 - Determining captured tables
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 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:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 3 - Locking captured tables
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Waiting a maximum of '10' seconds for each table lock
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 4 - Determining snapshot offset
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Creating initial offset context
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Read xlogStart at 'LSN{0/2349CE8}' from transaction '766'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Read xlogStart at 'LSN{0/2349CE8}' from transaction '766'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 5 - Reading structure of captured tables
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Reading structure of schema 'inventory'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 6 - Persisting schema history
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Snapshot step 7 - Snapshotting data
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Exporting data from table 'inventory.customers'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:07 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
For table 'inventory.customers' using select statement: 'SELECT * FROM
"inventory"."customers"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:08 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Finished exporting 4 records for table 'inventory.customers'; total duration
'00:00:00.075'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:08 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Exporting data from table 'inventory.geom'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:08 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
For table 'inventory.geom' using select statement: 'SELECT * FROM
"inventory"."geom"'
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:42:08 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
Stopping down connector
> Task :sdks:python:test-suites:dataflow:py39:postCommitIT
[gw1] [32mPASSED[0m
apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_table_schema_retrieve_specifying_only_table
apache_beam/io/gcp/bigquery_read_it_test.py::ReadTests::test_table_schema_retrieve_with_direct_read
> Task :sdks:python:test-suites:portable:py39:postCommitPy39IT
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 6:51:17 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
File "/usr/lib/python3.9/threading.py", line 930, in _bootstrap
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING:
Coordinator didn't stop in the expected time, shutting down executor now
self._bootstrap_inner()
File "/usr/lib/python3.9/threading.py", line 973, in _bootstrap_inner
self.run()
File "/usr/lib/python3.9/threading.py", line 910, in run
self._target(*self._args, **self._kwargs)
File
"/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/build/gradleenv/2022703443/lib/python3.9/site-packages/grpc/_channel.py",
line 273, in consume_request_iterator
request = next(request_iterator)
File
"/home/jenkins/jenkins-slave/workspace/beam_PostCommit_Python39/src/sdks/python/apache_beam/runners/worker/data_plane.py",
line 608, in _write_outputs
streams = [self._to_send.get()]
File "/usr/lib/python3.9/queue.py", line 171, in get
self.not_empty.wait()
File "/usr/lib/python3.9/threading.py", line 312, in wait
waiter.acquire()
~~~~~~~~~~~~~~~~~~~~ Stack of Thread-1496 (139793786722048) ~~~~~~~~~~~~~~~~~~~~
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 7:02:26 AM org.apache.beam.runners.fnexecution.logging.Slf4jLogWriter log
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 WARNING:
Operation ongoing in bundle 3 for
PTransform{id=external_12Read-from-debezium-ExternalTransform-beam-transform-org-apache-beam-debezium_read-v1--ParDo-KafkaSou/ProcessSizedElementsAndRestrictions0,
name=Read from
debezium/ExternalTransform(beam:transform:org.apache.beam:debezium_read:v1)/ParDo(KafkaSourceConsumer)/ParMultiDo(KafkaSourceConsumer)/ProcessSizedElementsAndRestrictions0,
state=process} for at least 06m09s without outputting or completing:
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.control.ExecutionStateSampler$ExecutionStateTracker.reset(ExecutionStateSampler.java:538)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.control.ProcessBundleHandler.processBundle(ProcessBundleHandler.java:590)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.FnHarness$$Lambda$112/1478995734.apply(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.control.BeamFnControlClient.delegateOnInstructionRequestType(BeamFnControlClient.java:150)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver.lambda$onNext$0(BeamFnControlClient.java:115)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.fn.harness.control.BeamFnControlClient$InboundObserver$$Lambda$121/1370108619.run(Unknown
Source)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
java.util.concurrent.FutureTask.run(FutureTask.java:266)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
org.apache.beam.sdk.util.UnboundedScheduledExecutorService$ScheduledFutureTask.run(UnboundedScheduledExecutorService.java:163)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 at
java.lang.Thread.run(Thread.java:750)
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 Jan 16,
2024 7:02:27 AM
org.apache.beam.runners.fnexecution.control.FnApiControlClientPoolService
getProcessBundleDescriptor
INFO apache_beam.utils.subprocess_server:subprocess_server.py:213 INFO:
getProcessBundleDescriptor request with id 1-40
FATAL: command execution failed
java.io.IOException: Backing channel 'apache-beam-jenkins-15' is disconnected.
at
hudson.remoting.RemoteInvocationHandler.channelOrFail(RemoteInvocationHandler.java:215)
at
hudson.remoting.RemoteInvocationHandler.invoke(RemoteInvocationHandler.java:285)
at com.sun.proxy.$Proxy208.isAlive(Unknown Source)
at hudson.Launcher$RemoteLauncher$ProcImpl.isAlive(Launcher.java:1215)
at hudson.Launcher$RemoteLauncher$ProcImpl.join(Launcher.java:1207)
at hudson.Launcher$ProcStarter.join(Launcher.java:524)
at hudson.plugins.gradle.Gradle.perform(Gradle.java:321)
at hudson.tasks.BuildStepMonitor$1.perform(BuildStepMonitor.java:20)
at
hudson.model.AbstractBuild$AbstractBuildExecution.perform(AbstractBuild.java:818)
at hudson.model.Build$BuildExecution.build(Build.java:199)
at hudson.model.Build$BuildExecution.doRun(Build.java:164)
at
hudson.model.AbstractBuild$AbstractBuildExecution.run(AbstractBuild.java:526)
at hudson.model.Run.execute(Run.java:1900)
at hudson.model.FreeStyleBuild.run(FreeStyleBuild.java:44)
at hudson.model.ResourceController.execute(ResourceController.java:101)
at hudson.model.Executor.run(Executor.java:442)
Caused by: hudson.remoting.Channel$OrderlyShutdown: Command Close created at
at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1313)
at hudson.remoting.Channel$1.handle(Channel.java:606)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Caused by: Command Close created at
at hudson.remoting.Command.<init>(Command.java:70)
at hudson.remoting.Channel$CloseCommand.<init>(Channel.java:1306)
at hudson.remoting.Channel.close(Channel.java:1480)
at hudson.remoting.Channel.close(Channel.java:1447)
at hudson.remoting.Channel$CloseCommand.execute(Channel.java:1312)
at hudson.remoting.Channel$1.handle(Channel.java:606)
at
hudson.remoting.SynchronousCommandTransport$ReaderThread.run(SynchronousCommandTransport.java:81)
Build step 'Invoke Gradle script' changed build result to FAILURE
Build step 'Invoke Gradle script' marked build as failure
ERROR: apache-beam-jenkins-15 is offline; cannot locate jdk_1.8_latest
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
