[Bug][connector-hive] filter '_SUCCESS' file in file list (apache#2235)…

… (apache#2236)
TyrantLucifer · Sep 18, 2022 · c1f0db7 · c1f0db7
1 parent 32c6c58
commit c1f0db7
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...e/seatunnel/connectors/seatunnel/hive/source/file/reader/format/AbstractReadStrategy.java b/...e/seatunnel/connectors/seatunnel/hive/source/file/reader/format/AbstractReadStrategy.java
@@ -72,8 +72,10 @@ public List<String> getFileNamesByPath(HadoopConf hadoopConf, String path) throw
                 continue;
             }
             if (fileStatus.isFile()) {
-
-                fileNames.add(fileStatus.getPath().toString());
+                // filter '_SUCCESS' file
+                if (!fileStatus.getPath().getName().equals("_SUCCESS")) {
+                    fileNames.add(fileStatus.getPath().toString());
+                }
             }
         }
         return fileNames;