diff --git a/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalogTest.java b/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalogTest.java
index a77ad8ca2..9455c7e66 100644
--- a/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalogTest.java
+++ b/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalogTest.java
@@ -40,6 +40,7 @@
 import org.apache.flink.table.expressions.ResolvedExpression;
 import org.apache.flink.table.expressions.utils.ResolvedExpressionMock;
 import org.apache.flink.table.factories.FactoryUtil;
+import org.apache.zookeeper.KeeperException;
 import org.junit.jupiter.api.AfterAll;
 import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
@@ -121,7 +122,15 @@ static void afterAll() {
     @BeforeEach
     void beforeEach() throws Exception {
         if (catalog != null) {
-            catalog.createDatabase(DEFAULT_DB, null, true);
+            try {
+                catalog.createDatabase(DEFAULT_DB, null, true);
+            } catch (CatalogException e) {
+                if (e.getCause() instanceof KeeperException.NodeExistsException) {
+                    // ignore
+                } else {
+                    throw e;
+                }
+            }
         }
     }
 
diff --git a/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/utils/FlinkConnectorOptionsUtilTest.java b/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/utils/FlinkConnectorOptionsUtilTest.java
index eeb4e5517..0f256da6c 100644
--- a/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/utils/FlinkConnectorOptionsUtilTest.java
+++ b/fluss-connectors/fluss-connector-flink/src/test/java/com/alibaba/fluss/connector/flink/utils/FlinkConnectorOptionsUtilTest.java
@@ -20,6 +20,7 @@
 import org.junit.jupiter.api.Test;
 
 import java.time.ZoneId;
+import java.util.TimeZone;
 
 import static com.alibaba.fluss.connector.flink.FlinkConnectorOptions.SCAN_STARTUP_TIMESTAMP;
 import static com.alibaba.fluss.connector.flink.utils.FlinkConnectorOptionsUtil.parseTimestamp;
@@ -41,7 +42,7 @@ void testParseTimestamp() {
                         parseTimestamp(
                                 "2023-12-09 23:09:12",
                                 SCAN_STARTUP_TIMESTAMP.key(),
-                                ZoneId.systemDefault()))
+                                TimeZone.getTimeZone("Asia/Shanghai").toZoneId()))
                 .isEqualTo(1702134552000L);
 
         assertThatThrownBy(
diff --git a/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java b/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java
index da731df99..4b3e59440 100644
--- a/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java
+++ b/fluss-server/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java
@@ -546,7 +546,6 @@ void testAddBucketCompletedSnapshot(@TempDir Path tempDir) throws Exception {
     }
 
     @Test
-    @Disabled
     void testCreateAndDropPartition() throws Exception {
         CoordinatorContext coordinatorContext = eventProcessor.getCoordinatorContext();
         // make sure all request to gateway should be successful