carbondata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From gvram...@apache.org
Subject [1/2] carbondata git commit: Add missing CleanFiles API during Update Operation
Date Wed, 28 Jun 2017 13:23:42 GMT
Repository: carbondata
Updated Branches:
  refs/heads/master bebad1007 -> ac2168a98


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/master
Commit: 354ecba96cb2182e3d2c167f5f0bbd5904bd4a79
Parents: bebad10
Author: root <pannerselvam.velmyl@gmail.com>
Authored: Fri Jun 23 13:42:25 2017 +0000
Committer: Venkata Ramana G <ramana.gollamudi@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" +


Mime
View raw message