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 7aa0cbd85 [hotfix] Remove StringUtils.isBlankString which is conflict 
with isBlank
7aa0cbd85 is described below

commit 7aa0cbd85d56e96cccba4cb5671ad2506d84e9a9
Author: Jingsong <[email protected]>
AuthorDate: Sat Aug 31 21:49:33 2024 +0800

    [hotfix] Remove StringUtils.isBlankString which is conflict with isBlank
---
 paimon-common/src/main/java/org/apache/paimon/CoreOptions.java    | 8 ++------
 .../src/main/java/org/apache/paimon/utils/StringUtils.java        | 7 -------
 2 files changed, 2 insertions(+), 13 deletions(-)

diff --git a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java 
b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
index 3c1bdf6fd..ecef7a9cb 100644
--- a/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
+++ b/paimon-common/src/main/java/org/apache/paimon/CoreOptions.java
@@ -1922,14 +1922,10 @@ public class CoreOptions implements Serializable {
         return options.get(PARTITION_TIMESTAMP_PATTERN);
     }
 
-    public int readBatchSize() {
-        return options.get(READ_BATCH_SIZE);
-    }
-
     public String consumerId() {
         String consumerId = options.get(CONSUMER_ID);
-        if (StringUtils.isBlankString(consumerId)) {
-            throw new RuntimeException("consumer id cannot be blank string");
+        if (consumerId != null && consumerId.isEmpty()) {
+            throw new RuntimeException("consumer id cannot be empty string.");
         }
         return consumerId;
     }
diff --git 
a/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java 
b/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
index 7b4bce9be..3dbc9779e 100644
--- a/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
+++ b/paimon-common/src/main/java/org/apache/paimon/utils/StringUtils.java
@@ -551,13 +551,6 @@ public class StringUtils {
         return true;
     }
 
-    public static boolean isBlankString(String str) {
-        if (str != null && str.length() == 0) {
-            return true;
-        }
-        return false;
-    }
-
     public static String quote(String str) {
         return "`" + str + "`";
     }

Reply via email to