Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Added logic to CREATE on Cluster when replicated mode is enabled #880

Open
wants to merge 24 commits into
base: 2.6.0
Choose a base branch
from

Merge branch '2.5.0' into 563-database-is-not-created-on-cluster-with…

c465523
Select commit
Loading
Failed to load commit list.
Sign in for the full log view
Open

Added logic to CREATE on Cluster when replicated mode is enabled #880

Merge branch '2.5.0' into 563-database-is-not-created-on-cluster-with…
c465523
Select commit
Loading
Failed to load commit list.
GitHub Actions / JUnit Test Report failed Oct 23, 2024 in 0s

129 tests run, 99 passed, 11 skipped, 19 failed.

Annotations

Check failure on line 138 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/MariaDBIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MariaDBIT.testMultipleDatabases 

Code: 60. DB::Exception: Unknown table expression identifier 'employees.audience' in scope SELECT * FROM employees.audience. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32853/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@180286269
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'employees.audience' in scope SELECT * FROM employees.audience. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32853/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@180286269
	at com.altinity.clickhouse.debezium.embedded.MariaDBIT.testMultipleDatabases(MariaDBIT.java:138)

Check failure on line 131 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/MySQLJsonIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MySQLJsonIT.testMultipleDatabases 

Code: 60. DB::Exception: Unknown table expression identifier 'employees.audience' in scope SELECT * FROM employees.audience. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32851/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@573313279
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'employees.audience' in scope SELECT * FROM employees.audience. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32851/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@573313279
	at com.altinity.clickhouse.debezium.embedded.MySQLJsonIT.testMultipleDatabases(MySQLJsonIT.java:131)

Check failure on line 112 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ReplicatedRMTIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

ReplicatedRMTIT.testReplicatedRMTAutoCreate{String}[1] 

Code: 390. DB::Exception: Table `string_types_MEDIUMTEXT_utf8mb4` doesn't exist. (CANNOT_GET_CREATE_TABLE_QUERY) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32862/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=client_1}]@1766419870
Raw output 
java.sql.BatchUpdateException: 
Code: 390. DB::Exception: Table `string_types_MEDIUMTEXT_utf8mb4` doesn't exist. (CANNOT_GET_CREATE_TABLE_QUERY) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32862/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=client_1}]@1766419870
	at com.altinity.clickhouse.debezium.embedded.ReplicatedRMTIT.testReplicatedRMTAutoCreate(ReplicatedRMTIT.java:112)

Check failure on line 128 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DatabaseOverrideIT.testDatabaseOverride 

Code: 81. DB::Exception: Database employees2 does not exist. Maybe you meant employees?. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32842/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1953032472
Raw output 
java.sql.BatchUpdateException: 
Code: 81. DB::Exception: Database employees2 does not exist. Maybe you meant employees?. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32842/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1953032472
	at com.altinity.clickhouse.debezium.embedded.cdc.DatabaseOverrideIT.testDatabaseOverride(DatabaseOverrideIT.java:128)

Check failure on line 111 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideInitialIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DatabaseOverrideInitialIT.testDatabaseOverride 

Code: 81. DB::Exception: Database employees2 does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32840/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1560005462
Raw output 
java.sql.BatchUpdateException: 
Code: 81. DB::Exception: Database employees2 does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32840/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1560005462
	at com.altinity.clickhouse.debezium.embedded.cdc.DatabaseOverrideInitialIT.testDatabaseOverride(DatabaseOverrideInitialIT.java:111)

Check failure on line 150 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DatabaseOverrideRRMTIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DatabaseOverrideRRMTIT.testDatabaseOverride 

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.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32833/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-184410927
Raw output 
java.sql.BatchUpdateException: 
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.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32833/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-184410927
	at com.altinity.clickhouse.debezium.embedded.cdc.DatabaseOverrideRRMTIT.testDatabaseOverride(DatabaseOverrideRRMTIT.java:150)

Check failure on line 166 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/DebeziumChangeEventCaptureIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DebeziumChangeEventCaptureIT.testIncrementingSequenceNumbers 

Code: 60. DB::Exception: Unknown table expression identifier 'newtable' in scope SELECT _version FROM newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32843/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@1279212593
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'newtable' in scope SELECT _version FROM newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32843/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@1279212593
	at com.altinity.clickhouse.debezium.embedded.cdc.DebeziumChangeEventCaptureIT.testIncrementingSequenceNumbers(DebeziumChangeEventCaptureIT.java:166)

Check failure on line 139 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/cdc/MultipleUpdatesWSameTimestampIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MultipleUpdatesWSameTimestampIT.testIncrementingSequenceNumberWithUpdates 

Code: 60. DB::Exception: Unknown table expression identifier 'newtable' in scope SELECT col2 FROM newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32835/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1443646663
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'newtable' in scope SELECT col2 FROM newtable FINAL WHERE col1 = 'a'. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32835/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1443646663
	at com.altinity.clickhouse.debezium.embedded.cdc.MultipleUpdatesWSameTimestampIT.testIncrementingSequenceNumberWithUpdates(MultipleUpdatesWSameTimestampIT.java:139)

Check failure on line 100 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableAddColumnIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

AlterTableAddColumnIT.testAddColumn 

Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.AlterTableAddColumnIT.testAddColumn(AlterTableAddColumnIT.java:100)

Check failure on line 86 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableChangeColumnIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

AlterTableChangeColumnIT.testChangeColumn 

Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.AlterTableChangeColumnIT.testChangeColumn(AlterTableChangeColumnIT.java:86)

Check failure on line 79 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/AlterTableModifyColumnIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

AlterTableModifyColumnIT.testModifyColumn 

Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.AlterTableModifyColumnIT.testModifyColumn(AlterTableModifyColumnIT.java:79)

Check failure on line 84 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

CreateTableDataTypesIT.testCreateTable 

Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.CreateTableDataTypesIT.testCreateTable(CreateTableDataTypesIT.java:84)

Check failure on line 95 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/CreateTableDataTypesTimeZoneIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

CreateTableDataTypesTimeZoneIT.testCreateTable 

Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
Raw output 
java.lang.NullPointerException: Cannot invoke "String.equalsIgnoreCase(String)" because the return value of "java.util.Map.get(Object)" is null
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.CreateTableDataTypesTimeZoneIT.testCreateTable(CreateTableDataTypesTimeZoneIT.java:95)

Check failure on line 92 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DateTimeWithTimeZoneIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DateTimeWithTimeZoneIT.testCreateTable 

Code: 60. DB::Exception: Unknown table expression identifier 'temporal_types_DATETIME' in scope SELECT * FROM temporal_types_DATETIME. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32814/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1611830354
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'temporal_types_DATETIME' in scope SELECT * FROM temporal_types_DATETIME. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32814/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-1611830354
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.DateTimeWithTimeZoneIT.testCreateTable(DateTimeWithTimeZoneIT.java:92)

Check failure on line 144 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.testCreateTable 

java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.testCreateTable(DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.java:144)
Raw output 
java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.testCreateTable(DateTimeWithUserProvidedTimeZoneSchemaOnlyIT.java:144)

Check failure on line 132 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MultipleDatabaseIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MultipleDatabaseIT.testMultipleDatabases 

Code: 81. DB::Exception: Database test_db does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32805/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@1022999917
Raw output 
java.sql.BatchUpdateException: 
Code: 81. DB::Exception: Database test_db does not exist. (UNKNOWN_DATABASE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32805/system, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@1022999917
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.MultipleDatabaseIT.testMultipleDatabases(MultipleDatabaseIT.java:132)

Check failure on line 692 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MySqlDDLParserListenerImplTest.testCreateDatabaseReplicated 

java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.MySqlDDLParserListenerImplTest.testCreateDatabaseReplicated(MySqlDDLParserListenerImplTest.java:692)
Raw output 
java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.MySqlDDLParserListenerImplTest.testCreateDatabaseReplicated(MySqlDDLParserListenerImplTest.java:692)

Check failure on line 677 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/MySqlDDLParserListenerImplTest.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

MySqlDDLParserListenerImplTest.testCreateDatabase 

java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.MySqlDDLParserListenerImplTest.testCreateDatabase(MySqlDDLParserListenerImplTest.java:677)
Raw output 
java.lang.AssertionError
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.MySqlDDLParserListenerImplTest.testCreateDatabase(MySqlDDLParserListenerImplTest.java:677)

Check failure on line 93 in sink-connector-lightweight/src/test/java/com/altinity/clickhouse/debezium/embedded/ddl/parser/TruncateTableIT.java

See this annotation in the file changed.

@github-actions github-actions / JUnit Test Report

TruncateTableIT.testIsDeleted 

Code: 60. DB::Exception: Unknown table expression identifier 'ship_class' in scope SELECT * FROM ship_class. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32816/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-2004857364
Raw output 
java.sql.BatchUpdateException: 
Code: 60. DB::Exception: Unknown table expression identifier 'ship_class' in scope SELECT * FROM ship_class. (UNKNOWN_TABLE) (version 24.9.2.42 (official build))
, server ClickHouseNode [uri=http://localhost:32816/employees, options={custom_settings=allow_experimental_object_type=1,insert_allow_materialized_columns=1,client_name=Client_1}]@-2004857364
	at com.altinity.clickhouse.debezium.embedded.ddl.parser.TruncateTableIT.testIsDeleted(TruncateTableIT.java:93)
View more details on GitHub Actions