Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2513#discussion_r203414480
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonLoadDataCommand.scala
---
@@ -355,6 +383,14 @@ case class CarbonLoadDataCommand(
val file = FileFactory.getCarbonFile(partitionLocation,
fileType)
CarbonUtil.deleteFoldersAndFiles(file)
}
+ if (isConcurrentLockRequired && !concurrentLoadLock.unlock()) {
+ LOGGER
+ .info("concurrent_load lock for table" + table.getTablePath +
+ "has been released successfully")
+ } else {
+ LOGGER.error(
+ "Unable to unlock concurrent_load lock for table" +
table.getTablePath);
+ }
--- End diff --
Unlocking should be in finally.
---
