[flink] Compact procedure does not process 'ALL' word (#3065)

apache · Mar 21, 2024 · 8e57754 · 8e57754
1 parent 617bff2
commit 8e57754
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java b/...paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/CompactProcedure.java
@@ -112,7 +112,7 @@ public String[] call(
                     "You must specify 'order strategy' and 'order by columns' both.");
         }
 
-        if (!(StringUtils.isBlank(partitions) || "ALL".equals(partitions))) {
+        if (!(StringUtils.isBlank(partitions))) {
             action.withPartitions(ParameterUtils.getPartitions(partitions.split(";")));
         }
 

diff --git a/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForDynamicBucketITCase.java b/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForDynamicBucketITCase.java
@@ -211,7 +211,7 @@ private SortCompactAction createAction(String orderStrategy, List<String> column
     private void callProcedure(String orderStrategy, List<String> orderByColumns) {
         callProcedure(
                 String.format(
-                        "CALL sys.compact('%s.%s', 'ALL', '%s', '%s')",
+                        "CALL sys.compact('%s.%s', '', '%s', '%s')",
                         database, tableName, orderStrategy, String.join(",", orderByColumns)),
                 false,
                 true);

diff --git a/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForUnawareBucketITCase.java b/...src/test/java/org/apache/paimon/flink/action/SortCompactActionForUnawareBucketITCase.java
@@ -381,7 +381,7 @@ private void callProcedure(
             String orderStrategy, String rangeStrategy, List<String> orderByColumns) {
         callProcedure(
                 String.format(
-                        "CALL sys.compact('%s.%s', 'ALL', '%s', '%s','sort-compaction.range-strategy=%s')",
+                        "CALL sys.compact('%s.%s', '', '%s', '%s','sort-compaction.range-strategy=%s')",
                         database,
                         tableName,
                         orderStrategy,