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 + "`";
}