See
<https://ci-beam.apache.org/job/beam_PreCommit_Java_Debezium_IO_Direct_Cron/1725/display/redirect?page=changes>
Changes:
[noreply] Bump github.com/aws/aws-sdk-go-v2 from 1.20.1 to 1.20.3 in /sdks
------------------------------------------
[...truncated 187.03 KB...]
INFO: including 'performance_schema.session_status' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_status' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.session_variables' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.session_variables' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_actors' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_actors' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_consumers' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_consumers' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_instruments' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_instruments' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_objects' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_objects' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.setup_timers' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.setup_timers' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_instances' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_instances' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_event_name'
among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_event_name' is filtered
out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.socket_summary_by_instance'
among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.socket_summary_by_instance' is filtered
out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_account' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_account' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_host' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_host' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_thread' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_thread' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.status_by_user' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.status_by_user' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_handles' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_handles' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_io_waits_summary_by_index_usage' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_index_usage' is
filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.table_io_waits_summary_by_table'
among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_io_waits_summary_by_table' is
filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including
'performance_schema.table_lock_waits_summary_by_table' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.table_lock_waits_summary_by_table' is
filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.threads' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.threads' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.user_variables_by_thread' among
known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.user_variables_by_thread' is filtered out
of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.users' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.users' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'performance_schema.variables_by_thread' among known
tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'performance_schema.variables_by_thread' is filtered out of
capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: including 'sys.sys_config' among known tables
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader
lambda$execute$2
INFO: 'sys.sys_config' is filtered out of capturing
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: snapshot continuing with database(s): [test, inventory]
Aug 21, 2023 3:46:31 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 6: generating DROP and CREATE statements to reflect current
database schemas:
Aug 21, 2023 3:46:35 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'
Aug 21, 2023 3:46:35 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'
Aug 21, 2023 3:46:35 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'
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: releasing global read lock to enable MySQL writes
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 7: blocked writes to MySQL for a total of 00:00:03.97
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanning contents of 1 tables while still in transaction
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: - scanning table 'inventory.customers' (1 of 1 tables)
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: For table 'inventory.customers' using select statement: 'SELECT *
FROM `inventory`.`customers`'
Aug 21, 2023 3:46:35 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.018
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 8: scanned 4 rows in 1 tables in 00:00:00.025
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Step 9: committing transaction
Aug 21, 2023 3:46:35 PM io.debezium.connector.mysql.SnapshotReader execute
INFO: Completed snapshot in 00:00:04.067
Aug 21, 2023 3:46:38 PM io.debezium.connector.common.BaseSourceTask stop
INFO: Stopping down connector
Aug 21, 2023 3:46:38 PM io.debezium.connector.mysql.MySqlConnectorTask
doStop
INFO: Stopping MySQL connector task
Aug 21, 2023 3:46:38 PM io.debezium.connector.mysql.ChainedReader stop
INFO: ChainedReader: Stopping the snapshot reader
Aug 21, 2023 3:46:38 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Aug 21, 2023 3:46:38 PM io.debezium.connector.mysql.AbstractReader stop
INFO: Discarding 0 unsent record(s) due to the connector shutting down
Aug 21, 2023 3:46:38 PM io.debezium.connector.mysql.MySqlConnectorTask
completeReaders
INFO: Connector task finished all work and is now shutdown
Aug 21, 2023 3:46:38 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
Aug 21, 2023 3:46:42 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
Aug 21, 2023 3:46:43 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@360f3e2}
Aug 21, 2023 3:46:43 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@1849d4db}
Aug 21, 2023 3:46:43 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@1849d4db}
Aug 21, 2023 3:46:43 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@1849d4db}
Aug 21, 2023 3:46:43 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@51a56b34}
Aug 21, 2023 3:46:43 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@51a56b34}
Aug 21, 2023 3:46:43 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@7a2a5106}
Aug 21, 2023 3:46:43 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{[-48, -105, 78, 48, -40, 76, -15, -70, 48, -57,
-97, 83, 80, 92, 109, -36, 82, -74, -22, 111, -122, 27, 36, 8, 31, -75, -32,
-100, 94, -111, -15, 17, -123, -123, 98, 75, -7, -42, -25, -52, -22, -97, 93,
-79, -116, 96, -79, -62, -34, 8, 43, -43, 103, 31, 10, -95, -82, 91, 110, -22,
41, -102, -32, 94, -124, 83, 0, 54, 127, -38, -95, -97, 65, 46, 106, -22, 72,
-4, 51, -49, -47, 38, 28, -64, 28, -62, -76, -12, 125, 42, 78, -86, 116, -60,
28, 102, 106, 83, -49, 24, -11, 4, -105, 56, -16, -72, 27, -113, 66, 52, -35,
108, 111, 118, -26, 48, -122, 62, 127, 41, 1, -90, -49, -107, 80, -80, -59,
53], KV{{topic=any, from=1, to=3, delay=0.2},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@7a2a5106}}
Aug 21, 2023 3:46:43 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@51a56b34}
Aug 21, 2023 3:46:43 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@7a2a5106}
Aug 21, 2023 3:46:43 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
Aug 21, 2023 3:46: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@2aeb936d}
Aug 21, 2023 3:46: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@5f51fed1}
Aug 21, 2023 3:46: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@5f51fed1}
Aug 21, 2023 3:46: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@6db6544e}
Aug 21, 2023 3:46: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@6db6544e}
Aug 21, 2023 3:46: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@5f51fed1}
Aug 21, 2023 3:46: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@3c48b40c}
Aug 21, 2023 3:46: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{[105, 95, 113, -45, 80, -25, -122, -128, -45, 89,
126, 57, 91, 27, -69, 90, 0, -82, -53, 107, -44, -40, 26, 3, 90, 22, 121, 49,
58, -93, -96, -91, -83, -112, -128, -94, 102, 86, 58, 7, -53, -42, 27, 67, 1,
-68, 10, 48, -62, 91, 85, -45, -43, -45, 124, 102, -51, -65, -59, -126, -42,
98, -118, -102, 127, 0, -24, -65, -72, 2, -80, 70, 25, -56, 102, -123, 121,
-20, -127, 33, -109, -115, 127, 75, 46, -127, 97, 53, -126, 64, 52, -24, -37,
29, 6, 1, -43, 96, 33, -61, 78, 45, -92, -114, -104, 86, -102, 97, -122, -41,
-40, -80, 85, -24, 118, 88, -6, -14, -39, 8, 29, 20, -124, 24, 73, -13, 55,
-78], KV{{topic=any, from=1, to=10, delay=0.4},
org.apache.beam.io.debezium.KafkaSourceConsumerFn$OffsetHolder@3c48b40c}}
Aug 21, 2023 3:46: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@6db6544e}
Aug 21, 2023 3:46: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@3c48b40c}
Aug 21, 2023 3:46:44 PM org.apache.kafka.common.config.AbstractConfig logAll
INFO: CounterSourceConnectorConfig values:
delay = 0.4
from = 1
to = 10
topic = any
Aug 21, 2023 3:46: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 7m 28s
112 actionable tasks: 70 executed, 42 from cache
Publishing build scan...
https://ge.apache.org/s/ejx6itt3zdkog
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]
