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/streaming_ingest Commit: 354ecba96cb2182e3d2c167f5f0bbd5904bd4a79 Parents: bebad10 Author: root <[email protected]> Authored: Fri Jun 23 13:42:25 2017 +0000 Committer: Venkata Ramana G <[email protected]> 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" +
