[flink] fix.

apache · Nov 26, 2024 · ea69e54 · ea69e54
1 parent d618b2f
commit ea69e54
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 3 deletions.
diff --git a/...k/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java b/...k/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java
@@ -62,9 +62,9 @@ public String[] call(ProcedureContext procedureContext, String tableId) throws E
         return call(procedureContext, tableId, "");
     }
 
-    public String[] call(ProcedureContext procedureContext, String tableId, String compactStrategy)
+    public String[] call(ProcedureContext procedureContext, String tableId, String partitions)
             throws Exception {
-        return call(procedureContext, tableId, "", "", compactStrategy, "", "");
+        return call(procedureContext, tableId, partitions, "", "", "", "");
     }
 
     public String[] call(

diff --git a/...8/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java b/...8/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java
@@ -68,10 +68,16 @@ public void testCompactDatabaseAndTable() {
                                 sql(
                                         "CALL sys.compact('default.T', '', '', '', 'sink.parallelism=1','pt=1')"))
                 .doesNotThrowAnyException();
-        assertThatCode(() -> sql("CALL sys.compact('default.T', '', 'zorder', 'k', '','','5s')"))
+        assertThatCode(
+                        () ->
+                                sql(
+                                        "CALL sys.compact('default.T', '', '' ,'zorder', 'k', '','','5s')"))
                 .message()
                 .contains("sort compact do not support 'partition_idle_time'.");
 
+        assertThatCode(() -> sql("CALL sys.compact('default.T', '', 'full' ,'', '', '','','')"))
+                .doesNotThrowAnyException();
+
         assertThatCode(() -> sql("CALL sys.compact_database('default')"))
                 .doesNotThrowAnyException();
     }