Github user gvramana commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/2420#discussion_r200234535
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/util/AlterTableUtil.scala ---
@@ -107,19 +107,10 @@ object AlterTableUtil {
*
* @param locks
* @param locksAcquired
- * @param dbName
- * @param tableName
- * @param tablePath
*/
- def releaseLocksManually(locks: List[ICarbonLock],
- locksAcquired: List[String],
- dbName: String,
- tableName: String,
- tablePath: String): Unit = {
- val lockLocation = tablePath
+ def releaseLocksManually(locks: List[ICarbonLock], locksAcquired:
List[String]): Unit = {
locks.zip(locksAcquired).foreach { case (carbonLock, lockType) =>
- val lockFilePath = CarbonTablePath.getLockFilePath(lockLocation,
lockType)
- if (carbonLock.releaseLockManually(lockFilePath)) {
+ if (carbonLock.unlock()) {
--- End diff --
locks can be removed as state updation is only in hive
---
