fix some test error

alibaba · Dec 2, 2024 · 1b31a66 · 1b31a66
1 parent 701f0f0
commit 1b31a66
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 3 deletions.
diff --git a/...ector-flink/src/test/java/com/alibaba/fluss/connector/flink/catalog/FlinkCatalogTest.java b/...ector-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/.../src/test/java/com/alibaba/fluss/connector/flink/utils/FlinkConnectorOptionsUtilTest.java b/.../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/...ver/src/test/java/com/alibaba/fluss/server/coordinator/CoordinatorEventProcessorTest.java b/...ver/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