(incubator-paimon) branch master updated: [hotfix] Clean todo in HiveCatalogITCaseBase (#2771)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new c7279c54e [hotfix] Clean todo in HiveCatalogITCaseBase (#2771)
c7279c54e is described below

commit c7279c54e6ab174d38f195e8298033517d584070
Author: yuzelin <33053040+yuze...@users.noreply.github.com>
AuthorDate: Tue Jan 23 15:04:21 2024 +0800

    [hotfix] Clean todo in HiveCatalogITCaseBase (#2771)
---
 .../org/apache/paimon/hive/HiveCatalogITCaseBase.java     | 15 ++-------------
 1 file changed, 2 insertions(+), 13 deletions(-)

diff --git 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
index 93cd93c04..874499856 100644
--- 
a/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
+++ 
b/paimon-hive/paimon-hive-connector-common/src/test/java/org/apache/paimon/hive/HiveCatalogITCaseBase.java
@@ -21,12 +21,10 @@ package org.apache.paimon.hive;
 import org.apache.paimon.catalog.Catalog;
 import org.apache.paimon.catalog.CatalogLock;
 import org.apache.paimon.catalog.Identifier;
-import org.apache.paimon.flink.DataCatalogTable;
 import org.apache.paimon.flink.FlinkCatalog;
 import org.apache.paimon.hive.annotation.Minio;
 import org.apache.paimon.hive.runner.PaimonEmbeddedHiveRunner;
 import org.apache.paimon.s3.MinioTestContainer;
-import org.apache.paimon.table.Table;
 
 import com.klarna.hiverunner.HiveShell;
 import com.klarna.hiverunner.annotations.HiveSQL;
@@ -36,7 +34,6 @@ import org.apache.flink.table.api.TableEnvironment;
 import org.apache.flink.table.api.TableException;
 import org.apache.flink.table.api.ValidationException;
 import org.apache.flink.table.api.internal.TableEnvironmentImpl;
-import org.apache.flink.table.catalog.ObjectPath;
 import org.apache.flink.table.catalog.exceptions.DatabaseAlreadyExistException;
 import org.apache.flink.table.catalog.exceptions.DatabaseNotEmptyException;
 import org.apache.flink.table.catalog.exceptions.DatabaseNotExistException;
@@ -912,15 +909,7 @@ public abstract class HiveCatalogITCaseBase {
                         "    'metastore.tag-to-partition' = 'dt'",
                         ")"));
         tEnv.executeSql("INSERT INTO t VALUES (1, 10), (2, 20)").await();
-
-        // TODO modify to CALL after Flink 1.18
-        Table table =
-                ((DataCatalogTable)
-                                tEnv.getCatalog(tEnv.getCurrentCatalog())
-                                        .get()
-                                        .getTable(new 
ObjectPath(tEnv.getCurrentDatabase(), "t")))
-                        .table();
-        table.createTag("2023-10-16", 1);
+        tEnv.executeSql("CALL sys.create_tag('test_db.t', '2023-10-16', 1)");
 
         assertThat(hiveShell.executeQuery("SHOW PARTITIONS t"))
                 .containsExactlyInAnyOrder("dt=2023-10-16");
@@ -934,7 +923,7 @@ public abstract class HiveCatalogITCaseBase {
         // another tag
 
         tEnv.executeSql("INSERT INTO t VALUES (3, 30), (4, 40)").await();
-        table.createTag("2023-10-17", 2);
+        tEnv.executeSql("CALL sys.create_tag('test_db.t', '2023-10-17', 2)");
 
         assertThat(hiveShell.executeQuery("SELECT * FROM t"))
                 .containsExactlyInAnyOrder(