[Feature][Connector-V2][File] Allow the user to set the row delimiter…

… as an empty string (apache#3854) Co-authored-by: zhaoliang01 <[email protected]>
harveyyue · Feb 7, 2023 · ad3fdf7 · ad3fdf7
1 parent 1a81d4f
commit ad3fdf7
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java b/...c/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java
@@ -68,8 +68,7 @@ public BaseFileSinkConfig(@NonNull Config config) {
             this.fieldDelimiter = config.getString(BaseSinkConfig.FIELD_DELIMITER.key());
         }
 
-        if (config.hasPath(BaseSinkConfig.ROW_DELIMITER.key()) &&
-                StringUtils.isNotEmpty(config.getString(BaseSinkConfig.ROW_DELIMITER.key()))) {
+        if (config.hasPath(BaseSinkConfig.ROW_DELIMITER.key())) {
             this.rowDelimiter = config.getString(BaseSinkConfig.ROW_DELIMITER.key());
         }