[CARBONDATA-2298]Delete segment lock files before update metadata

If there are some COMPACTED segments and their last modified time is within one hour, the segment lock files deletion operation will not be executed. This closes #2124
apache · Apr 2, 2018 · 6374d36 · 6374d36
1 parent 0992b3b
commit 6374d36
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/apache/carbondata/core/statusmanager/SegmentStatusManager.java b/core/src/main/java/org/apache/carbondata/core/statusmanager/SegmentStatusManager.java
@@ -891,6 +891,8 @@ public static void deleteLoadsAndUpdateMetadata(
       CarbonTable carbonTable,
       boolean isForceDeletion,
       List<PartitionSpec> partitionSpecs) throws IOException {
+    // delete the expired segment lock files
+    CarbonLockUtil.deleteExpiredSegmentLockFiles(carbonTable);
     if (isLoadDeletionRequired(carbonTable.getMetadataPath())) {
       AbsoluteTableIdentifier identifier = carbonTable.getAbsoluteTableIdentifier();
       ReturnTuple tuple = isUpdationRequired(isForceDeletion, carbonTable, identifier);
@@ -963,8 +965,6 @@ public static void deleteLoadsAndUpdateMetadata(
         }
       }
     }
-    // delete the expired segment lock files
-    CarbonLockUtil.deleteExpiredSegmentLockFiles(carbonTable);
   }
 
   /**