See
<https://ci-beam.apache.org/job/beam_PreCommit_Java_Debezium_IO_Direct_Cron/1841/display/redirect>
Changes:
------------------------------------------
[...truncated 182.05 KB...]
INFO: including 'performance_schema.session_status' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_status' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.session_variables' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_variables' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_actors' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_actors' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_consumers' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_consumers' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_instruments' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_instruments' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_objects' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_objects' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_timers' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_timers' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_instances' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_instances' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_event_name'
among known tables
Sep 19, 2023 3:48:20 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 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_instance'
among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_instance' is filtered
out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_account' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_account' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_host' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_host' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_thread' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_thread' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_user' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_user' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_handles' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_handles' is filtered out of capturing
Sep 19, 2023 3:48:20 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 3:48:20 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 3:48:20 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 3:48:20 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 3:48:20 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 3:48:20 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 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.threads' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.threads' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.user_variables_by_thread' among
known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.user_variables_by_thread' is filtered out
of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.users' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.users' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.variables_by_thread' among known
tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.variables_by_thread' is filtered out of
capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'sys.sys_config' among known tables
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'sys.sys_config' is filtered out of capturing
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: snapshot continuing with database(s): [test, inventory]
Sep 19, 2023 3:48:20 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 6: generating DROP and CREATE statements to reflect current
database schemas:
Sep 19, 2023 3:48:27 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 3:48:27 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 3:48:27 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 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: releasing global read lock to enable MySQL writes
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: blocked writes to MySQL for a total of 00:00:07.463
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanning contents of 1 tables while still in transaction
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: - scanning table 'inventory.customers' (1 of 1 tables)
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: For table 'inventory.customers' using select statement: 'SELECT *
FROM `inventory`.`customers`'
Sep 19, 2023 3:48:27 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.044
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanned 4 rows in 1 tables in 00:00:00.052
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 9: committing transaction
Sep 19, 2023 3:48:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Completed snapshot in 00:00:07.647
Sep 19, 2023 3:48:30 PM io.debezium.connector.common.BaseSourceTask stop
INFO: Stopping down connector
Sep 19, 2023 3:48:30 PM io.debezium.connector.mysql.MySqlConnectorTask
doStop
INFO: Stopping MySQL connector task
Sep 19, 2023 3:48:30 PM io.debezium.connector.mysql.ChainedReader stop
INFO: ChainedReader: Stopping the snapshot reader
Sep 19, 2023 3:48:30 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Sep 19, 2023 3:48:30 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Sep 19, 2023 3:48:30 PM io.debezium.connector.mysql.MySqlConnectorTask
completeReaders
INFO: Connector task finished all work and is now shutdown
Sep 19, 2023 3:48:30 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 3:48:39 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 3:48:41 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@6fe4cc7b}
Sep 19, 2023 3:48:42 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@55520314}
Sep 19, 2023 3:48:42 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@55520314}
Sep 19, 2023 3:48:42 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@55520314}
Sep 19, 2023 3:48:42 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@458da375}
Sep 19, 2023 3:48:42 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@458da375}
Sep 19, 2023 3:48:42 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@458da375}
Sep 19, 2023 3:48:42 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@1ff5c118}
Sep 19, 2023 3:48:42 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{[-1, -2, 8, 45, -8, -80, 42, -125, -44, 21, 106,
78, 38, 25, 102, 57, -116, -49, -27, 90, 34, -67, 106, 99, -52, 63, 1, -49, 21,
59, 26, 28, -128, -127, -82, 19, -101, 56, -106, -99, -69, -58, 90, 69, -4,
108, -3, -52, 89, 97, 44, -53, -97, -26, -80, 85, 6, -39, -119, -123, 83, -66,
124, -126, -96, 98, 63, 47, 71, -25, 126, 93, 65, 17, -63, 60, 79, -49, 68,
111, 104, 113, 69, 35, 38, -95, 122, 124, -82, -3, 37, -47, -95, -1, 13, -72,
17, 23, 69, -49, 97, -51, 38, 22, 27, -107, -77, -113, 31, -91, 11, -104, -45,
13, -80, 13, -91, -83, 79, -51, -116, -108, 103, 120, 88, -122, -54, -82],
KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@1ff5c118}}
Sep 19, 2023 3:48:42 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@1ff5c118}
Sep 19, 2023 3:48:42 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 3:48:44 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@9473007}
Sep 19, 2023 3:48:44 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@784ab645}
Sep 19, 2023 3:48:44 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@784ab645}
Sep 19, 2023 3:48:44 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@784ab645}
Sep 19, 2023 3:48:44 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@20c0ae43}
Sep 19, 2023 3:48:44 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@20c0ae43}
Sep 19, 2023 3:48:44 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@20c0ae43}
Sep 19, 2023 3:48:44 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@345a8ab5}
Sep 19, 2023 3:48:44 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{[-52, -29, -50, 30, 98, 26, 67, -68, -63, -115,
-123, -20, 32, -32, -26, 97, 124, -61, -122, 87, -18, -79, 122, -45, -53, 68,
115, 34, 6, 123, -105, -21, -24, 127, 98, -15, 83, -7, -18, -21, -72, 74, 100,
-74, -37, -95, -8, -7, -53, -98, 37, 78, 117, 2, -66, -38, -57, 19, 46, -9,
-11, -45, -50, 48, 122, 77, 52, 101, 60, 61, -41, -14, -47, 50, -58, 47, -57,
121, 43, 38, 88, 83, 122, -108, 13, 18, -13, -55, -60, 88, 125, 36, 108, -1,
31, -86, -117, 123, -93, 25, -33, 30, 122, -9, -42, -28, 31, -122, -5, -49,
-37, -57, -48, 86, 31, -80, 113, 46, -123, 68, 103, -23, -5, -7, -84, -43, -42,
0], KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@345a8ab5}}
Sep 19, 2023 3:48:44 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@345a8ab5}
Sep 19, 2023 3:48:44 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.4
from = 1
to = 10
topic = any
Sep 19, 2023 3:48:45 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
4 tests completed, 1 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 14m 31s
112 actionable tasks: 70 executed, 42 from cache
Publishing build scan...
https://ge.apache.org/s/rxk57chccezki
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]
