Github user ravipesala commented on a diff in the pull request:

    https://github.com/apache/carbondata/pull/2045#discussion_r174233092
  
    --- Diff: 
core/src/main/java/org/apache/carbondata/core/locks/CarbonLockUtil.java ---
    @@ -107,4 +114,36 @@ public static int getLockProperty(String property, int 
defaultValue) {
         }
       }
     
    +  /**
    +   * Currently the segment lock files are not deleted immediately when 
unlock,
    +   * so it needs to delete expired lock files before delete loads.
    +   */
    +  public static void deleteExpiredSegmentLockFiles(CarbonTable 
carbonTable) {
    +    LoadMetadataDetails[] details =
    --- End diff --
    
    I think you can better list the segment lock files from locks folder and 
check the modified time of it and remove . Otherwise if you do as per 
tablestatus then namenode calls would be many.


---

Reply via email to