[hotfix] Fix RemoveOrphanFilesProcedure parallelism error

herefree · Sep 11, 2024 · 0ff226b · 0ff226b
1 parent 6c7f32c
commit 0ff226b
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 3 deletions.
diff --git a/...link-1.18/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java b/...link-1.18/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java
@@ -77,7 +77,7 @@ public String[] call(
         String tableName = identifier.getObjectName();
 
         Map<String, String> dynamicOptions =
-                !StringUtils.isNullOrWhitespaceOnly(parallelism)
+                StringUtils.isNullOrWhitespaceOnly(parallelism)
                         ? Collections.emptyMap()
                         : new HashMap<String, String>() {
                             {

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
@@ -39,6 +39,7 @@
 
 /** Ensure that the legacy multiply overloaded CALL with positional arguments can be invoked. */
 public class ProcedurePositionalArgumentsITCase extends CatalogITCaseBase {
+
     @Test
     public void testCompactDatabaseAndTable() {
         sql(

diff --git a/...nk-common/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java b/...nk-common/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java
@@ -83,7 +83,7 @@ public String[] call(
         String tableName = identifier.getObjectName();
 
         Map<String, String> dynamicOptions =
-                !StringUtils.isNullOrWhitespaceOnly(parallelism)
+                StringUtils.isNullOrWhitespaceOnly(parallelism)
                         ? Collections.emptyMap()
                         : new HashMap<String, String>() {
                             {

diff --git a/...rk-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java b/...rk-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java
@@ -92,7 +92,7 @@ public InternalRow[] call(InternalRow args) {
         String tableId = args.getString(0);
         String parallelism = args.isNullAt(3) ? null : args.getString(3);
         Map<String, String> dynamicOptions =
-                !StringUtils.isNullOrWhitespaceOnly(parallelism)
+                StringUtils.isNullOrWhitespaceOnly(parallelism)
                         ? Collections.emptyMap()
                         : new HashMap<String, String>() {
                             {
-Original file line number
+Diff line change
@@ Expand Up / @@ -39,6 +39,7 @@ @@
     /** Ensure that the legacy multiply overloaded CALL with positional arguments can be invoked. */
     public class ProcedurePositionalArgumentsITCase extends CatalogITCaseBase {
         @Test
         public void testCompactDatabaseAndTable() {
             sql(
@@ Expand Down @@