[hotfix] Fix RemoveOrphanFilesProcedure parallelism error

JingsongLi · JingsongLi · commit 0ff226b8709d · 2024-09-11T18:58:37.000+08:00
diff --git a/paimon-flink/paimon-flink-1.18/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java b/paimon-flink/paimon-flink-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/paimon-flink/paimon-flink-1.18/src/test/java/org/apache/paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java b/paimon-flink/paimon-flink-1.18/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/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java b/paimon-flink/paimon-flink-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/paimon-spark/paimon-spark-common/src/main/java/org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java b/paimon-spark/paimon-spark-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 number	Diff line change
`@@ -77,7 +77,7 @@ public String[] call(`
`77`	`77`	`String tableName = identifier.getObjectName();`
`78`	`78`
`79`	`79`	`Map<String, String> dynamicOptions =`
`80`		`- !StringUtils.isNullOrWhitespaceOnly(parallelism)`
	`80`	`+ StringUtils.isNullOrWhitespaceOnly(parallelism)`
`81`	`81`	`? Collections.emptyMap()`
`82`	`82`	`: new HashMap<String, String>() {`
`83`	`83`	`{`
Original file line number	Diff line number	Diff line change
`@@ -83,7 +83,7 @@ public String[] call(`
`83`	`83`	`String tableName = identifier.getObjectName();`
`84`	`84`
`85`	`85`	`Map<String, String> dynamicOptions =`
`86`		`- !StringUtils.isNullOrWhitespaceOnly(parallelism)`
	`86`	`+ StringUtils.isNullOrWhitespaceOnly(parallelism)`
`87`	`87`	`? Collections.emptyMap()`
`88`	`88`	`: new HashMap<String, String>() {`
`89`	`89`	`{`
Original file line number	Diff line number	Diff line change
`@@ -92,7 +92,7 @@ public InternalRow[] call(InternalRow args) {`
`92`	`92`	`String tableId = args.getString(0);`
`93`	`93`	`String parallelism = args.isNullAt(3) ? null : args.getString(3);`
`94`	`94`	`Map<String, String> dynamicOptions =`
`95`		`- !StringUtils.isNullOrWhitespaceOnly(parallelism)`
	`95`	`+ StringUtils.isNullOrWhitespaceOnly(parallelism)`
`96`	`96`	`? Collections.emptyMap()`
`97`	`97`	`: new HashMap<String, String>() {`
`98`	`98`	`{`