You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by zo...@apache.org on 2022/10/13 13:46:44 UTC
[incubator-seatunnel] branch dev updated: [hotfix][connector][file] Solved the bug of can not parse '\t' as delimiter from config file (#3083)
This is an automated email from the ASF dual-hosted git repository.
zongwen pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new bfde59675 [hotfix][connector][file] Solved the bug of can not parse '\t' as delimiter from config file (#3083)
bfde59675 is described below
commit bfde59675441e340d7580aa9c883e0aa9585f1ab
Author: TyrantLucifer <Ty...@gmail.com>
AuthorDate: Thu Oct 13 21:46:37 2022 +0800
[hotfix][connector][file] Solved the bug of can not parse '\t' as delimiter from config file (#3083)
---
.../connectors/seatunnel/file/config/BaseTextFileConfig.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java
index 4659d1913..dcbe0b948 100644
--- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java
+++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java
@@ -50,11 +50,11 @@ public class BaseTextFileConfig implements DelimiterConfig, CompressConfig, Seri
throw new RuntimeException("compress not support now");
}
- if (config.hasPath(Constant.FIELD_DELIMITER) && !StringUtils.isBlank(config.getString(Constant.FIELD_DELIMITER))) {
+ if (config.hasPath(Constant.FIELD_DELIMITER) && StringUtils.isNotEmpty(config.getString(Constant.FIELD_DELIMITER))) {
this.fieldDelimiter = config.getString(Constant.FIELD_DELIMITER);
}
- if (config.hasPath(Constant.ROW_DELIMITER) && !StringUtils.isBlank(config.getString(Constant.ROW_DELIMITER))) {
+ if (config.hasPath(Constant.ROW_DELIMITER) && StringUtils.isNotEmpty(config.getString(Constant.ROW_DELIMITER))) {
this.rowDelimiter = config.getString(Constant.ROW_DELIMITER);
}