Github user jackylk commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1467#discussion_r149281235
--- Diff:
integration/spark-common/src/main/scala/org/apache/carbondata/api/CarbonStore.scala
---
@@ -79,16 +82,45 @@ object CarbonStore {
dbName: String,
tableName: String,
storePath: String,
- carbonTable: CarbonTable, forceTableClean: Boolean): Unit = {
+ carbonTable: CarbonTable, forceTableClean: Boolean
+ ): Unit = {
LOGGER.audit(s"The clean files request has been received for
$dbName.$tableName")
+ var carbonCleanFilesLock: ICarbonLock = null
try {
- DataManagementFunc.cleanFiles(dbName, tableName, storePath,
carbonTable, forceTableClean)
- LOGGER.audit(s"Clean files operation is success for
$dbName.$tableName.")
+ val identifier = new CarbonTableIdentifier(dbName, tableName, "")
+ carbonCleanFilesLock =
+ CarbonLockFactory.getCarbonLockObj(identifier,
LockUsage.CLEAN_FILES_LOCK)
} catch {
case ex: Exception =>
sys.error(ex.getMessage)
+ return
}
- Seq.empty
+ try {
--- End diff --
fixed
---
