(paimon) branch master updated: [hotfix] Fix RemoveOrphanFilesProcedure parallelism error

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 0ff226b87 [hotfix] Fix RemoveOrphanFilesProcedure parallelism error
0ff226b87 is described below

commit 0ff226b8709dcea0ab11c70c26115f3c8d6b3799
Author: Jingsong <jingsongl...@gmail.com>
AuthorDate: Wed Sep 11 18:58:37 2024 +0800

    [hotfix] Fix RemoveOrphanFilesProcedure parallelism error
---
 .../org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java   | 2 +-
 .../paimon/flink/procedure/ProcedurePositionalArgumentsITCase.java      | 1 +
 .../org/apache/paimon/flink/procedure/RemoveOrphanFilesProcedure.java   | 2 +-
 .../org/apache/paimon/spark/procedure/RemoveOrphanFilesProcedure.java   | 2 +-
 4 files changed, 4 insertions(+), 3 deletions(-)

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
index 47e2a56c0..6e160ebbc 100644
--- 
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 class RemoveOrphanFilesProcedure extends ProcedureBase 
{
         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
index 967eb9d65..da2eaef0b 100644
--- 
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 @@ import static org.junit.jupiter.api.Assertions.assertThrows;
 
 /** 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
index b7a857e45..1d6cb0886 100644
--- 
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 class RemoveOrphanFilesProcedure extends ProcedureBase 
{
         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
index 6c977e0da..0735fa8ce 100644
--- 
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 class RemoveOrphanFilesProcedure extends BaseProcedure 
{
         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>() {
                             {