above

databendcloud · Dec 21, 2023 · 4aebb47 · 4aebb47
1 parent 4f4dfe6
commit 4aebb47
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/debezium-server-databend-sink/src/main/java/io/debezium/server/databend/DatabendUtil.java b/debezium-server-databend-sink/src/main/java/io/debezium/server/databend/DatabendUtil.java
@@ -260,7 +260,7 @@ public static Map<String, String> findDecimalFields(DatabendChangeEvent.Schema s
     }
 
     public static boolean isSchemaChanged(DatabendChangeEvent.Schema schema) {
-        if (schema.keySchema().isNull()) {
+        if (schema.keySchema().isNull() || schema.keySchema().get("name").isNull()) {
             return false;
         }
         String schemaNameStr = schema.keySchema().get("name").textValue();