From 84508fcb659cee36f0061c10e1bfb9151209ee60 Mon Sep 17 00:00:00 2001 From: lightzhao <40714172+lightzhao@users.noreply.github.com> Date: Mon, 16 Jan 2023 21:46:56 +0800 Subject: [PATCH] [Feature][Connector-V2][File] Allow the user to set the row delimiter as an empty string (#3854) Co-authored-by: zhaoliang01 --- .../connectors/seatunnel/file/config/BaseFileSinkConfig.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java index 42b31adc9ee..57e8079cb05 100644 --- a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java +++ b/seatunnel-connectors-v2/connector-file/connector-file-base/src/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()); }