From 4aebb471d2adacd3d51f578855597435a9b940c5 Mon Sep 17 00:00:00 2001
From: hantmac <hantmac@outlook.com>
Date: Thu, 21 Dec 2023 14:39:14 +0800
Subject: [PATCH] above

---
 .../src/main/java/io/debezium/server/databend/DatabendUtil.java | 2 +-
 1 file changed, 1 insertion(+), 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
index 7dd503d..e29796b 100644
--- 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();