Skip to content
Pull Request Pipeline

Added logic to detect connector class(MySQL or PostgreSQL) and change offset commit message #1021

Sign in to view logs

Added logic to detect connector class(MySQL or PostgreSQL) and change offset commit message

Added logic to detect connector class(MySQL or PostgreSQL) and change offset commit message #1021

Triggered via pull request January 28, 2025 16:19
@subkanthisubkanthi
synchronize #975
973-include-postgres-lsn-information-in-batch-marked-as-completed
Status Cancelled
Total duration 3h 27m 57s
Artifacts 4

pull-request.yml

on: pull_request
build-kafka-lightweight  /  build
6m 23s
build-kafka-lightweight / build
testflows-kafka  /  testflows-kafka
2h 21m
testflows-kafka / testflows-kafka
testflows-lightweight  /  testflows-lightweight
3h 17m
testflows-lightweight / testflows-lightweight
testflows-lightweight  /  testflows-lightweight-replicated
3h 17m
testflows-lightweight / testflows-lightweight-replicated
java-tests-kafka  /  java-kafka
1m 31s
java-tests-kafka / java-kafka
java-tests-lightweight  /  java-lightweight
1h 6m
java-tests-lightweight / java-lightweight
Fit to window
Zoom out
Zoom in

Annotations

42 errors and 1 warning
ClickHouseDebeziumEmbeddedPostgresDecoderBufsDockerIT.testDecoderBufsPlugin: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ClickHouseDebeziumEmbeddedPostgresDecoderBufsDockerIT.java#L101
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.ClickHouseDebeziumEmbeddedPostgresDecoderBufsDockerIT.testDecoderBufsPlugin(ClickHouseDebeziumEmbeddedPostgresDecoderBufsDockerIT.java:101)
ClickHouseDebeziumEmbeddedPostgresPgoutputDockerIT.testPgOutputPlugin: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ClickHouseDebeziumEmbeddedPostgresPgoutputDockerIT.java#L105
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.ClickHouseDebeziumEmbeddedPostgresPgoutputDockerIT.testPgOutputPlugin(ClickHouseDebeziumEmbeddedPostgresPgoutputDockerIT.java:105)
MySQLGenerateColumnsTest.testMySQLGeneratedColumns: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/MySQLGenerateColumnsTest.java#L107
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
MySQLJsonIT.testMultipleDatabases: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/MySQLJsonIT.java#L131
Code: 60. DB::Exception: Unknown table expression identifier 'employees.audience' in scope SELECT * FROM employees.audience. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
PostgresInitialDockerIT.testDecoderBufsPlugin: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/PostgresInitialDockerIT.java#L102
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.PostgresInitialDockerIT.testDecoderBufsPlugin(PostgresInitialDockerIT.java:102)
PostgresInitialDockerWKeeperMapStorageIT.testDecoderBufsPlugin: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/PostgresInitialDockerWKeeperMapStorageIT.java#L125
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.PostgresInitialDockerWKeeperMapStorageIT.testDecoderBufsPlugin(PostgresInitialDockerWKeeperMapStorageIT.java:125)
PostgresPgoutputMultipleSchemaIT.testMultipleSchemaReplication: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/PostgresPgoutputMultipleSchemaIT.java#L115
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.PostgresPgoutputMultipleSchemaIT.testMultipleSchemaReplication(PostgresPgoutputMultipleSchemaIT.java:115)
ReplicatedRMTClickHouse22TIT.testReplicatedRMTAutoCreate{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ReplicatedRMTClickHouse22TIT.java#L109
Code: 390. DB::Exception: Table `string_types_MEDIUMTEXT_utf8mb4` doesn't exist. (CANNOT_GET_CREATE_TABLE_QUERY) (version 22.3.20.29 (official build))
ReplicatedRMTDDLClickHouse22TIT.testReplicatedRMTAutoCreate{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ReplicatedRMTDDLClickHouse22TIT.java#L111
Code: 390. DB::Exception: Table `string_types_MEDIUMTEXT_utf8mb4` doesn't exist. (CANNOT_GET_CREATE_TABLE_QUERY) (version 22.3.20.29 (official build))
ReplicatedRMTDDLIT.testReplicatedRMTAutoCreate{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ReplicatedRMTDDLIT.java#L138
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.ReplicatedRMTDDLIT.testReplicatedRMTAutoCreate(ReplicatedRMTDDLIT.java:138)
ReplicatedRMTIT.testReplicatedRMTAutoCreate{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ReplicatedRMTIT.java#L112
Code: 390. DB::Exception: Table `string_types_MEDIUMTEXT_utf8mb4` doesn't exist. (CANNOT_GET_CREATE_TABLE_QUERY) (version 24.12.3.47 (official build))
DatabaseOverrideIT.testDatabaseOverride: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideIT.java#L128
Code: 81. DB::Exception: Database employees2 does not exist. Maybe you meant employees?. (UNKNOWN_DATABASE) (version 24.12.3.47 (official build))
DatabaseOverrideInitialIT.testDatabaseOverride: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideInitialIT.java#L111
Code: 81. DB::Exception: Database employees2 does not exist. (UNKNOWN_DATABASE) (version 24.12.3.47 (official build))
DatabaseOverrideRRMTIT.testDatabaseOverride: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideRRMTIT.java#L150
Code: 60. DB::Exception: Unknown table expression identifier 'employees2.newtable' in scope SELECT col2 FROM employees2.newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
DebeziumChangeEventCaptureIT.testIncrementingSequenceNumbers: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCaptureIT.java#L166
Code: 60. DB::Exception: Unknown table expression identifier 'newtable' in scope SELECT _version FROM newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
MultipleUpdatesWSameTimestampIT.testIncrementingSequenceNumberWithUpdates: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/MultipleUpdatesWSameTimestampIT.java#L146
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.cdc.MultipleUpdatesWSameTimestampIT.testIncrementingSequenceNumberWithUpdates(MultipleUpdatesWSameTimestampIT.java:146)
AlterTableAddColumnIT.testAddColumn: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableAddColumnIT.java#L100
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
AlterTableChangeColumnIT.testChangeColumn: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableChangeColumnIT.java#L86
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
AlterTableModifyColumnIT.testModifyColumn: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableModifyColumnIT.java#L79
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
AutoCreateTableIT.testAutoCreateTable{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AutoCreateTableIT.java#L102
Code: 60. DB::Exception: Unknown table expression identifier 'new-table' in scope SELECT count(*) FROM `new-table`. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
AutoCreateTableIT.testAutoCreateTable{String}[2]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AutoCreateTableIT.java#L102
Code: 60. DB::Exception: Unknown table expression identifier 'new-table' in scope SELECT count(*) FROM `new-table`. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
CreateTableDataTypesIT.testCreateTable: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesIT.java#L84
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
CreateTableDataTypesTimeZoneIT.testCreateTable: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesTimeZoneIT.java#L95
Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
DDLIgnoreRegExIT.testDDLIgnoreRegex: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DDLIgnoreRegExIT.java#L104
expected:<null> but was:<alter table sales analyze partition p2022>
DateTimeWithTimeZoneIT.testCreateTable: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DateTimeWithTimeZoneIT.java#L92
Code: 60. DB::Exception: Unknown table expression identifier 'temporal_types_DATETIME' in scope SELECT * FROM temporal_types_DATETIME. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
DateTimeWithUserProvidedDifferentTimeZoneIT.testCreateTable: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DateTimeWithUserProvidedDifferentTimeZoneIT.java#L155
Code: 60. DB::Exception: Unknown table expression identifier 'temporal_types_DATETIME' in scope SELECT * FROM temporal_types_DATETIME. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.testCreateTable: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.java#L144
java.lang.AssertionError at com.altinity.clickhouse.debezium.embedded.ddl.parser.DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.testCreateTable(DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.java:144)
IsDeletedColumnsIT.testIsDeleted{String}[1]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/IsDeletedColumnsIT.java#L102
Code: 60. DB::Exception: Unknown table expression identifier 'new_table' in scope SELECT * FROM new_table. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
IsDeletedColumnsIT.testIsDeleted{String}[2]: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/IsDeletedColumnsIT.java#L102
Code: 60. DB::Exception: Unknown table expression identifier 'new_table' in scope SELECT * FROM new_table. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
MultipleDatabaseIT.testMultipleDatabases: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MultipleDatabaseIT.java#L132
Code: 81. DB::Exception: Database test_db does not exist. (UNKNOWN_DATABASE) (version 24.12.3.47 (official build))
TruncateTableIT.testIsDeleted: sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/TruncateTableIT.java#L93
Code: 60. DB::Exception: Unknown table expression identifier 'ship_class' in scope SELECT * FROM ship_class. (UNKNOWN_TABLE) (version 24.12.3.47 (official build))
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
java-tests-lightweight / java-lightweight
Port already in use. Make sure no other process is using port 7000 and try again.
testflows-kafka / testflows-kafka
Process completed with exit code 1.
testflows-lightweight / testflows-lightweight
The run was canceled by @github-actions[bot].
testflows-lightweight / testflows-lightweight
The operation was canceled.
testflows-lightweight / testflows-lightweight-replicated
The run was canceled by @github-actions[bot].
testflows-lightweight / testflows-lightweight-replicated
The operation was canceled.
build-kafka-lightweight / build
No files were found with the provided path: sink-connector-lightweight/target/clickhouse-debezium-embedded-0.0.9.jar. No artifacts will be uploaded.

Artifacts

Produced during runtime
Name Size
clickhouse-sink-connector-kafka-975-15ed130e9f5b8035c0c308d7178e50a2298aa788.jar
14.1 MB
testflows-sink-connector-kafka-artefacts
36.6 MB
testflows-sink-connector-lightweight-artefacts
16.6 MB
testflows-sink-connector-lightweight-replicated-artefacts
16.6 MB