You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@carbondata.apache.org by ja...@apache.org on 2017/06/28 16:41:16 UTC
[19/20] carbondata git commit: Add missing CleanFiles API during
Update Operation
Add missing CleanFiles API during Update Operation
Project: http://git-wip-us.apache.org/repos/asf/carbondata/repo
Commit: http://git-wip-us.apache.org/repos/asf/carbondata/commit/354ecba9
Tree: http://git-wip-us.apache.org/repos/asf/carbondata/tree/354ecba9
Diff: http://git-wip-us.apache.org/repos/asf/carbondata/diff/354ecba9
Branch: refs/heads/encoding_override
Commit: 354ecba96cb2182e3d2c167f5f0bbd5904bd4a79
Parents: bebad10
Author: root <pa...@gmail.com>
Authored: Fri Jun 23 13:42:25 2017 +0000
Committer: Venkata Ramana G <ra...@huawei.com>
Committed: Wed Jun 28 18:52:36 2017 +0530
----------------------------------------------------------------------
.../scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala | 1 +
1 file changed, 1 insertion(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/carbondata/blob/354ecba9/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala
----------------------------------------------------------------------
diff --git a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala
index 1790ea2..664cbae 100644
--- a/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala
+++ b/integration/spark-common/src/main/scala/org/apache/carbondata/spark/rdd/DataManagementFunc.scala
@@ -361,6 +361,7 @@ object DataManagementFunc {
LOGGER.info("Clean files lock has been successfully acquired.")
deleteLoadsAndUpdateMetadata(dbName, tableName, storePath,
isForceDeletion = true, carbonTable)
+ CarbonUpdateUtil.cleanUpDeltaFiles(carbonTable, true)
} else {
val errorMsg = "Clean files request is failed for " +
s"$dbName.$tableName" +