See
<https://ci-beam.apache.org/job/beam_PreCommit_Java_Debezium_IO_Direct_Cron/1206/display/redirect>
Changes:
------------------------------------------
[...truncated 186.84 KB...]
INFO: including 'performance_schema.session_status' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_status' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.session_variables' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_variables' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_actors' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_actors' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_consumers' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_consumers' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_instruments' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_instruments' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_objects' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_objects' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_timers' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_timers' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_instances' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_instances' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_event_name'
among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_event_name' is filtered
out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_instance'
among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_instance' is filtered
out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_account' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_account' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_host' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_host' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_thread' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_thread' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_user' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_user' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_handles' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_handles' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_io_waits_summary_by_index_usage' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_index_usage' is
filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_io_waits_summary_by_table'
among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_table' is
filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_lock_waits_summary_by_table' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_lock_waits_summary_by_table' is
filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.threads' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.threads' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.user_variables_by_thread' among
known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.user_variables_by_thread' is filtered out
of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.users' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.users' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.variables_by_thread' among known
tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.variables_by_thread' is filtered out of
capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'sys.sys_config' among known tables
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'sys.sys_config' is filtered out of capturing
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: snapshot continuing with database(s): [test, inventory]
Apr 13, 2023 9:50:27 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 6: generating DROP and CREATE statements to reflect current
database schemas:
Apr 13, 2023 9:50:30 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'
Apr 13, 2023 9:50:30 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'
Apr 13, 2023 9:50:30 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'
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: releasing global read lock to enable MySQL writes
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: blocked writes to MySQL for a total of 00:00:02.885
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanning contents of 1 tables while still in transaction
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: - scanning table 'inventory.customers' (1 of 1 tables)
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: For table 'inventory.customers' using select statement: 'SELECT *
FROM `inventory`.`customers`'
Apr 13, 2023 9:50:30 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.013
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanned 4 rows in 1 tables in 00:00:00.018
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 9: committing transaction
Apr 13, 2023 9:50:30 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Completed snapshot in 00:00:02.948
Apr 13, 2023 9:50:33 PM io.debezium.connector.common.BaseSourceTask stop
INFO: Stopping down connector
Apr 13, 2023 9:50:33 PM io.debezium.connector.mysql.MySqlConnectorTask
doStop
INFO: Stopping MySQL connector task
Apr 13, 2023 9:50:33 PM io.debezium.connector.mysql.ChainedReader stop
INFO: ChainedReader: Stopping the snapshot reader
Apr 13, 2023 9:50:33 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Apr 13, 2023 9:50:33 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Apr 13, 2023 9:50:33 PM io.debezium.connector.mysql.MySqlConnectorTask
completeReaders
INFO: Connector task finished all work and is now shutdown
Apr 13, 2023 9:50:33 PM
org.apache.beam.io.debezium.DebeziumReadSchemaTransformProvider$1$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
Apr 13, 2023 9:50: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
Apr 13, 2023 9:50: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@5cf786f0}
Apr 13, 2023 9:50: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@2b7142bd}
Apr 13, 2023 9:50: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@2b7142bd}
Apr 13, 2023 9:50: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@2b7142bd}
Apr 13, 2023 9:50: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@51a36a86}
Apr 13, 2023 9:50: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@51a36a86}
Apr 13, 2023 9:50: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@51a36a86}
Apr 13, 2023 9:50: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@6a457215}
Apr 13, 2023 9:50: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{[-13, -12, -14, -110, 63, -80, -110, 28, -116,
68, -64, -85, -115, 15, 86, 96, 69, -15, -50, 72, 116, -23, 108, 119, 69, 114,
-65, -128, -38, -121, -84, -55, -65, -111, -3, 80, -13, 33, -95, -125, -15,
-19, -7, -57, -30, -82, 97, 1, 44, 5, -55, -78, 119, 84, -47, -128, 66, 90,
-26, -14, -81, -122, -57, -71, 83, -91, -126, -23, -39, -85, -126, -84, 112,
114, -112, 45, -100, -71, 102, 60, 113, -81, -38, 115, -41, -86, -32, -109,
-25, -113, -104, -76, -42, -30, 83, -30, -46, 34, 121, -120, 79, -99, 103, 49,
-17, 82, 57, -35, 75, 78, -33, -20, 24, 7, -69, -64, -33, -117, 46, 7, 40, -48,
-17, 97, -87, -44, 13, -90], KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@6a457215}}
Apr 13, 2023 9:50: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@6a457215}
Apr 13, 2023 9:50:37 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
Apr 13, 2023 9:50:38 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@1fcef025}
Apr 13, 2023 9:50:38 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@599439e3}
Apr 13, 2023 9:50:38 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@599439e3}
Apr 13, 2023 9:50:38 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@599439e3}
Apr 13, 2023 9:50:38 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@1c8527bb}
Apr 13, 2023 9:50:38 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@1c8527bb}
Apr 13, 2023 9:50:38 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@1c8527bb}
Apr 13, 2023 9:50:38 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@1d1f55f}
Apr 13, 2023 9:50:38 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{[-43, -34, 124, 104, -32, 107, -32, 62, 63, 51,
120, 116, -16, 68, 77, -127, -7, 97, 62, 3, -38, -110, 76, -60, 24, 84, -26,
-118, -80, 95, 8, 80, -91, 112, -95, -119, 4, -86, -36, 117, 76, -55, -25, -18,
-14, -83, -127, -11, -88, -90, -123, 84, -47, -27, 83, 77, 68, 111, 8, -121,
61, 109, -121, 10, 14, 20, -113, -78, 58, -99, 7, -21, 5, -20, 104, -32, -33,
-25, -111, 87, -26, -49, 5, 77, -87, 89, 107, 86, -46, -50, 91, 4, -48, 81,
-38, 101, -93, 86, 24, 124, 26, 24, -6, -7, -73, 77, 127, 14, -35, -11, -11,
111, 68, 11, 113, -10, -54, -106, -81, 50, 70, -115, -92, -76, -21, -1, 61,
-31], KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@1d1f55f}}
Apr 13, 2023 9:50:38 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@1d1f55f}
Apr 13, 2023 9:50:38 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.4
from = 1
to = 10
topic = any
Apr 13, 2023 9:50:39 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:176
Caused by: java.lang.AssertionError at
DebeziumIOMySqlConnectorIT.java:165
Caused by: java.lang.AssertionError at
DebeziumIOMySqlConnectorIT.java:168
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.5.1/userguide/command_line_interface.html#sec:command_line_warnings
BUILD FAILED in 7m 39s
111 actionable tasks: 73 executed, 38 from cache
Publishing build scan...
https://gradle.com/s/jc4a6seaxsoc4
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]
