You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@carbondata.apache.org by KanakaKumar <gi...@git.apache.org> on 2017/12/22 11:26:03 UTC
[GitHub] carbondata pull request #1702: [CARBONDATA-1896] Clean files operation impro...
Github user KanakaKumar commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1702#discussion_r158474524
--- Diff: integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/management/CarbonLoadDataCommand.scala ---
@@ -178,6 +178,7 @@ case class CarbonLoadDataCommand(
// First system has to partition the data first and then call the load data
LOGGER.info(s"Initiating Direct Load for the Table : ($dbName.$tableName)")
GlobalDictionaryUtil.updateTableMetadataFunc = updateTableMetadata
+ DataLoadingUtil.deleteLoadsAndUpdateMetadata(isForceDeletion = false, table)
--- End diff --
Please add the purpose why we have to move deletion call from CarbonDataRDDFactory.scala to here
---