Adjusting how we "ignore" the column

ClickHouse · Jun 27, 2024 · 162b054 · 162b054
1 parent 5a59e06
commit 162b054
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/src/main/java/com/clickhouse/kafka/connect/sink/db/helper/ClickHouseHelperClient.java b/src/main/java/com/clickhouse/kafka/connect/sink/db/helper/ClickHouseHelperClient.java
@@ -211,11 +211,6 @@ public Table describeTable(String tableName) {
                     continue;
                 }
 
-                if (fieldDescriptor.isSubcolumn() && fieldDescriptor.getName().endsWith(".null")) {
-                    LOGGER.debug("Skipping column {} as it is a subcolumn from a Nullable", fieldDescriptor.getName());
-                    continue;
-                }
-
                 if (fieldDescriptor.hasDefault()) {
                     table.hasDefaults(true);
                 }

diff --git a/src/test/java/com/clickhouse/kafka/connect/sink/db/mapping/TableTest.java b/src/test/java/com/clickhouse/kafka/connect/sink/db/mapping/TableTest.java
@@ -44,7 +44,7 @@ public void extractNullables() {
         Table table = chc.describeTable(tableName);
         assertNotNull(table);
         assertEquals(table.getRootColumnsList().size(), 2);
-        assertEquals(table.getAllColumnsList().size(), 2);
+        assertEquals(table.getAllColumnsList().size(), 3);
         ClickHouseTestHelpers.dropTable(chc, tableName);
     }