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

)
apache · Jul 22, 2022 · db04651 · db04651
1 parent cf5327c
commit db04651
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;