See
<https://ci-beam.apache.org/job/beam_PreCommit_Java_Debezium_IO_Direct_Cron/1842/display/redirect>
Changes:
------------------------------------------
[...truncated 196.25 KB...]
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_actors' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_actors' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_consumers' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_consumers' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_instruments' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_instruments' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_objects' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_objects' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_timers' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_timers' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_instances' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_instances' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_event_name'
among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_event_name' is filtered
out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_instance'
among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_instance' is filtered
out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_account' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_account' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_host' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_host' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_thread' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_thread' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_user' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_user' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_handles' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_handles' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_io_waits_summary_by_index_usage' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_index_usage' is
filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_io_waits_summary_by_table'
among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_table' is
filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_lock_waits_summary_by_table' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_lock_waits_summary_by_table' is
filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.threads' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.threads' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.user_variables_by_thread' among
known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.user_variables_by_thread' is filtered out
of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.users' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.users' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.variables_by_thread' among known
tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.variables_by_thread' is filtered out of
capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'sys.sys_config' among known tables
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'sys.sys_config' is filtered out of capturing
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: snapshot continuing with database(s): [test, inventory]
Sep 19, 2023 9:47:14 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 6: generating DROP and CREATE statements to reflect current
database schemas:
Sep 19, 2023 9:47:18 PM io.debezium.util.SchemaNameAdjuster lambda$create$1
WARNING: The Kafka Connect schema name
'beam-pipeline-server.inventory.customers.Value' is not a valid Avro schema
name, so replacing with 'beam_pipeline_server.inventory.customers.Value'
Sep 19, 2023 9:47:18 PM io.debezium.util.SchemaNameAdjuster lambda$create$1
WARNING: The Kafka Connect schema name
'beam-pipeline-server.inventory.customers.Key' is not a valid Avro schema name,
so replacing with 'beam_pipeline_server.inventory.customers.Key'
Sep 19, 2023 9:47:18 PM io.debezium.util.SchemaNameAdjuster lambda$create$1
WARNING: The Kafka Connect schema name
'beam-pipeline-server.inventory.customers.Envelope' is not a valid Avro schema
name, so replacing with 'beam_pipeline_server.inventory.customers.Envelope'
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: releasing global read lock to enable MySQL writes
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: blocked writes to MySQL for a total of 00:00:03.597
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanning contents of 1 tables while still in transaction
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: - scanning table 'inventory.customers' (1 of 1 tables)
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: For table 'inventory.customers' using select statement: 'SELECT *
FROM `inventory`.`customers`'
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$14
INFO: Step 8: - Completed scanning a total of 4 rows from table
'inventory.customers' after 00:00:00.016
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanned 4 rows in 1 tables in 00:00:00.021
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 9: committing transaction
Sep 19, 2023 9:47:18 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Completed snapshot in 00:00:03.677
Sep 19, 2023 9:47:22 PM io.debezium.connector.common.BaseSourceTask stop
INFO: Stopping down connector
Sep 19, 2023 9:47:22 PM io.debezium.connector.mysql.MySqlConnectorTask
doStop
INFO: Stopping MySQL connector task
Sep 19, 2023 9:47:22 PM io.debezium.connector.mysql.ChainedReader stop
INFO: ChainedReader: Stopping the snapshot reader
Sep 19, 2023 9:47:22 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Sep 19, 2023 9:47:22 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Sep 19, 2023 9:47:22 PM io.debezium.connector.mysql.MySqlConnectorTask
completeReaders
INFO: Connector task finished all work and is now shutdown
Sep 19, 2023 9:47:22 PM
org.apache.beam.io.debezium.DebeziumReadSchemaTransformProvider$1 expand
INFO: Computed schema for table inventory.customers from MYSQL: Fields:
Field{name=before, description=, type=ROW<id INT32 NOT NULL, first_name
STRING NOT NULL, last_name STRING NOT NULL, email STRING NOT NULL>,
options={{}}}
Field{name=after, description=, type=ROW<id INT32 NOT NULL, first_name
STRING NOT NULL, last_name STRING NOT NULL, email STRING NOT NULL>,
options={{}}}
Field{name=source, description=, type=ROW<version STRING NOT NULL,
connector STRING NOT NULL, name STRING NOT NULL, ts_ms INT64 NOT NULL, snapshot
STRING, db STRING NOT NULL, table STRING, server_id INT64 NOT NULL, gtid
STRING, file STRING NOT NULL, pos INT64 NOT NULL, row INT32 NOT NULL, thread
INT64, query STRING> NOT NULL, options={{}}}
Field{name=op, description=, type=STRING NOT NULL, options={{}}}
Field{name=ts_ms, description=, type=INT64, options={{}}}
Field{name=transaction, description=, type=ROW<id STRING NOT NULL,
total_order INT64 NOT NULL, data_collection_order INT64 NOT NULL>, options={{}}}
Encoding positions:
{op=3, before=0, after=1, source=2, ts_ms=4, transaction=5}
Options:{{primaryKeyColumns=Option{type=ARRAY<STRING NOT NULL> NOT NULL,
value=[id]}}}UUID: null
org.apache.beam.io.debezium.KafkaSourceConsumerFnTest >
testStoppableKafkaSourceConsumerFn STANDARD_ERROR
Sep 19, 2023 9:47:36 PM org.apache.beam.sdk.coders.SerializableCoder
checkEqualsMethodDefined
WARNING: Can't verify serialized elements of type OffsetHolder have well
defined equals method. This may produce incorrect results on some
PipelineRunner implementations
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@61f79608}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@3b4e306e}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@3b4e306e}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@3b4e306e}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@267a984c}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@267a984c}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@267a984c}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@35d58e61}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{[122, 63, -29, -28, -106, 24, -17, -49, -49, -19,
1, 23, 58, 51, -60, -108, -70, -112, -83, 39, -75, 0, 36, -75, -106, 29, -64,
125, 126, -71, -40, 105, -32, -69, 34, -70, -13, 111, 113, -119, 34, -73, 110,
103, -60, 115, -100, -59, -33, -64, 77, 23, 0, -121, -66, -42, -86, 5, -102,
24, -86, -19, -17, 64, 11, -50, -83, 63, -92, 79, -55, 58, -29, -88, 69, 98,
-26, 30, -84, 58, 68, -76, -91, 74, 39, -111, 71, -38, 8, 50, -79, -64, 114,
104, -100, 25, -125, -104, -85, 24, -76, 41, -31, 50, -127, -23, -119, -4, 45,
-10, 53, -26, -22, -50, 44, -75, -28, 45, -45, -43, 78, 12, 55, 63, -84, -68,
101, -60], KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@35d58e61}}
Sep 19, 2023 9:47:37 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@35d58e61}
Sep 19, 2023 9:47:38 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.2
from = 1
to = 3
topic = any
org.apache.beam.io.debezium.KafkaSourceConsumerFnTest >
testKafkaSourceConsumerFn STANDARD_ERROR
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@61c63bd4}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@14d9d026}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@14d9d026}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@14d9d026}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@69f288dd}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@69f288dd}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@69f288dd}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@66db9007}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{[-7, 54, -37, 30, -75, 109, 87, 1, -77, -63, 81,
-43, -48, 57, 123, -100, -102, -26, 31, 85, 17, -2, 98, -94, 123, 59, 76, -35,
-95, 54, -101, 28, 37, 98, 76, 63, 24, 12, 65, -117, 67, 118, 77, 49, 29, 61,
34, 48, 80, -63, -63, -25, 123, -61, 7, 34, 69, 79, 81, 28, 89, 118, 27, 42,
-59, -89, 33, 95, -15, -83, -26, -105, 58, -55, -114, -54, -17, -50, 96, 8, 52,
55, 9, -95, 25, 9, 121, -100, -97, 30, 26, -79, -58, 126, -6, 9, -44, 87, 13,
-83, 88, 62, -17, 56, 58, 3, 27, 43, -113, 78, -127, -41, 84, 106, -65, 5, -85,
70, 54, -85, 115, 81, 38, -7, -128, 103, 3, -6], KV{{topic=any, from=1, to=10,
delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@66db9007}}
Sep 19, 2023 9:47:39 PM
org.apache.beam.sdk.util.MutationDetectors$CodedValueMutationDetector
verifyUnmodifiedThrowingCheckedExceptions
WARNING: Coder of type class org.apache.beam.sdk.coders.KvCoder has a
#structuralValue method which does not return true when the encoding of the
elements is equal. Element KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@66db9007}
Sep 19, 2023 9:47:39 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.4
from = 1
to = 10
topic = any
Sep 19, 2023 9:47:40 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.4
from = 1
to = 10
topic = any
> Task :sdks:java:io:debezium:check
> Task :sdks:java:io:debezium:build
> Task :sdks:java:io:debezium:integrationTest
org.apache.beam.io.debezium.DebeziumIOMySqlConnectorIT >
testDebeziumSchemaTransformMysqlRead FAILED
org.apache.beam.sdk.Pipeline$PipelineExecutionException at
DebeziumIOMySqlConnectorIT.java:175
Caused by: java.lang.AssertionError at
DebeziumIOMySqlConnectorIT.java:164
Caused by: java.lang.AssertionError at
DebeziumIOMySqlConnectorIT.java:167
org.apache.beam.io.debezium.DebeziumIOPostgresSqlConnectorIT >
testDebeziumSchemaTransformPostgresRead FAILED
org.apache.beam.sdk.Pipeline$PipelineExecutionException at
DebeziumIOPostgresSqlConnectorIT.java:146
Caused by: java.lang.RuntimeException at KafkaSourceConsumerFn.java:269
Caused by: org.apache.kafka.connect.errors.ConnectException at
ErrorHandler.java:42
Caused by: io.debezium.DebeziumException at
PostgresReplicationConnection.java:308
Caused by: org.postgresql.util.PSQLException at
QueryExecutorImpl.java:2553
4 tests completed, 2 failed
> Task :sdks:java:io:debezium:integrationTest FAILED
FAILURE: Build failed with an exception.
* What went wrong:
Execution failed for task ':sdks:java:io:debezium:integrationTest'.
> There were failing tests. See the report at:
> file://<https://ci-beam.apache.org/job/beam_PreCommit_Java_Debezium_IO_Direct_Cron/ws/src/sdks/java/io/debezium/build/reports/tests/integrationTest/index.html>
* Try:
> Run with --stacktrace option to get the stack trace.
> Run with --info or --debug option to get more log output.
* Get more help at https://help.gradle.org
Deprecated Gradle features were used in this build, making it incompatible with
Gradle 8.0.
You can use '--warning-mode all' to show the individual deprecation warnings
and determine if they come from your own scripts or plugins.
See
https://docs.gradle.org/7.6.2/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 8m 52s
112 actionable tasks: 71 executed, 41 from cache
Publishing build scan...
https://ge.apache.org/s/jmojent27rjoc
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]
