This is an automated email from the ASF dual-hosted git repository.
fanjia pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 5e03d22d6 [Bugfix] [Connector-V2] [File] Fix read temp file (#4876)
5e03d22d6 is described below
commit 5e03d22d6cb5bfdaf941b7749e0a313bd6ab2f86
Author: xiaofan2012 <[email protected]>
AuthorDate: Mon Jun 5 17:22:48 2023 +0800
[Bugfix] [Connector-V2] [File] Fix read temp file (#4876)
Co-authored-by: wantao <[email protected]>
---
.../connectors/seatunnel/file/source/reader/AbstractReadStrategy.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java
index 0bd638a42..54e706624 100644
---
a/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java
+++
b/seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java
@@ -128,7 +128,8 @@ public abstract class AbstractReadStrategy implements
ReadStrategy {
}
if (fileStatus.isFile()) {
// filter '_SUCCESS' file
- if (!fileStatus.getPath().getName().equals("_SUCCESS")) {
+ if (!fileStatus.getPath().getName().equals("_SUCCESS")
+ && !fileStatus.getPath().getName().startsWith(".")) {
String filePath = fileStatus.getPath().toString();
if (!readPartitions.isEmpty()) {
for (String readPartition : readPartitions) {
