[GitHub] carbondata pull request #1638: [CARBONDATA-1879][Streaming] Support alter ta...

[QiangCai]

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

    https://github.com/apache/carbondata/pull/1638#discussion_r156834271
  
    --- Diff: 
streaming/src/main/java/org/apache/carbondata/streaming/segment/StreamSegment.java
 ---
    @@ -180,6 +182,70 @@ public static String close(CarbonTable table, String 
segmentId)
         }
       }
     
    +  /**
    +   * change the status of the segment from "streaming" to "streaming 
finish"
    +   */
    +  public static void finishStreaming(CarbonTable carbonTable) throws 
Exception {
    +    ICarbonLock lock = CarbonLockFactory.getCarbonLockObj(
    +        carbonTable.getTableInfo().getOrCreateAbsoluteTableIdentifier(),
    +        LockUsage.TABLE_STATUS_LOCK);
    +    try {
    +      if (lock.lockWithRetries()) {
    +        ICarbonLock streamingLock = CarbonLockFactory.getCarbonLockObj(
    +            
carbonTable.getTableInfo().getOrCreateAbsoluteTableIdentifier(),
    +            LockUsage.STREAMING_LOCK);
    --- End diff --
    
    fixed


---