[hotfix][connector][file] Solved the bug of can not parse '\t' as del…

…imiter from config file (#3083)
apache · Oct 13, 2022 · bfde596 · bfde596
1 parent 3b73cc7
commit bfde596
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseTextFileConfig.java
@@ -50,11 +50,11 @@ public BaseTextFileConfig(@NonNull Config config) {
             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);
         }