Github user ravipesala commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1975#discussion_r170170644
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/datamap/CarbonDropDataMapCommand.scala
---
@@ -65,8 +65,9 @@ case class CarbonDropDataMapCommand(
catalog.checkSchemasModifiedTimeAndReloadTable(TableIdentifier(tableName,
Some(dbName)))
val carbonLocks: scala.collection.mutable.ListBuffer[ICarbonLock] =
ListBuffer()
try {
+ forceDropTableFromMetaStore(sparkSession)
locksToBeAcquired foreach {
- lock => carbonLocks +=
CarbonLockUtil.getLockObject(tableIdentifier, lock)
+ lock => carbonLocks +=
CarbonLockUtil.getLockObject(tableIdentifier, lock)
--- End diff --
correct the format
---
