You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ty...@apache.org on 2023/01/16 13:47:02 UTC
[incubator-seatunnel] branch dev updated: [Feature][Connector-V2][File] Allow the user to set the row delimiter as an empty string (#3854)
This is an automated email from the ASF dual-hosted git repository.
tyrantlucifer 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 84508fcb6 [Feature][Connector-V2][File] Allow the user to set the row delimiter as an empty string (#3854)
84508fcb6 is described below
commit 84508fcb659cee36f0061c10e1bfb9151209ee60
Author: lightzhao <40...@users.noreply.github.com>
AuthorDate: Mon Jan 16 21:46:56 2023 +0800
[Feature][Connector-V2][File] Allow the user to set the row delimiter as an empty string (#3854)
Co-authored-by: zhaoliang01 <zh...@58.com>
---
.../seatunnel/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 42b31adc9..57e8079cb 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 class BaseFileSinkConfig implements DelimiterConfig, CompressConfig, Seri
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());
}