[FLINK-20230][table] FileSystemOutputFormat should delete file using …

…FileSystemFactory This closes apache#15541
pppsunil · Apr 12, 2021 · 562f31a · 562f31a
1 parent 73f66d9
commit 562f31a
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/...runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java b/...runtime-blink/src/main/java/org/apache/flink/table/filesystem/FileSystemOutputFormat.java
@@ -27,7 +27,6 @@
 import org.apache.flink.streaming.api.functions.sink.filesystem.OutputFileConfig;
 import org.apache.flink.table.api.TableException;
 
-import java.io.File;
 import java.io.IOException;
 import java.io.Serializable;
 import java.util.LinkedHashMap;
@@ -93,7 +92,10 @@ public void finalizeGlobal(int parallelism) {
         } catch (Exception e) {
             throw new TableException("Exception in finalizeGlobal", e);
         } finally {
-            new File(tmpPath.getPath()).delete();
+            try {
+                fsFactory.create(tmpPath.toUri()).delete(tmpPath, true);
+            } catch (IOException ignore) {
+            }
         }
     }