[core] Catalog list tables sorted (#2254)

apache · Nov 13, 2023 · 9fd5550 · 9fd5550
1 parent 1d8e592
commit 9fd5550
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 1 deletion.
diff --git a/paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java b/paimon-core/src/main/java/org/apache/paimon/catalog/AbstractCatalog.java
@@ -40,6 +40,7 @@
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
+import java.util.stream.Collectors;
 
 import static org.apache.paimon.options.CatalogOptions.LINEAGE_META;
 
@@ -139,7 +140,7 @@ public List<String> listTables(String databaseName) throws DatabaseNotExistExcep
             throw new DatabaseNotExistException(databaseName);
         }
 
-        return listTablesImpl(databaseName);
+        return listTablesImpl(databaseName).stream().sorted().collect(Collectors.toList());
     }
 
     protected abstract List<String> listTablesImpl(String databaseName);

diff --git a/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkReadITCase.java b/paimon-spark/paimon-spark-common/src/test/java/org/apache/paimon/spark/SparkReadITCase.java
@@ -311,6 +311,16 @@ public void testConflictOption() {
                         "Can not set changelog-producer on table without primary keys");
     }
 
+    @Test
+    public void testShowTablesSorted() {
+        spark.sql("create table t3(id int, name string)");
+        spark.sql("create table t4(id int, name string)");
+        List<Row> tables = spark.sql("SHOW TABLES").collectAsList();
+        assertThat(tables.toString())
+                .isEqualTo(
+                        "[[default,t1,false], [default,t2,false], [default,t3,false], [default,t4,false]]");
+    }
+
     @Test
     public void testCreateTableWithNullablePk() {
         spark.sql(