Depend on results of Hive file deletion.

Fixes trinodb#2296
ddrinka · Mar 5, 2020 · 6753e49 · 6753e49
1 parent bb7002d
commit 6753e49
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/presto-hive/src/main/java/io/prestosql/plugin/hive/SortingFileWriter.java b/presto-hive/src/main/java/io/prestosql/plugin/hive/SortingFileWriter.java
@@ -223,8 +223,7 @@ private void mergeFiles(Iterable<TempFile> files, Consumer<Page> consumer)
 
             for (TempFile tempFile : files) {
                 Path file = tempFile.getPath();
-                fileSystem.delete(file, false);
-                if (fileSystem.exists(file)) {
+                if (!fileSystem.delete(file, false)) {
                     throw new IOException("Failed to delete temporary file: " + file);
                 }
             }
@@ -252,8 +251,7 @@ private void writeTempFile(Consumer<TempFileWriter> consumer)
     private void cleanupFile(Path file)
     {
         try {
-            fileSystem.delete(file, false);
-            if (fileSystem.exists(file)) {
+            if (!fileSystem.delete(file, false)) {
                 throw new IOException("Delete failed");
             }
         }