Github user mohammadshahidkhan commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1418#discussion_r150248529
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/execution/command/CarbonCreateTableCommand.scala
---
@@ -37,11 +37,13 @@ case class CarbonCreateTableCommand(
}
override def processSchema(sparkSession: SparkSession): Seq[Row] = {
- val storePath = CarbonEnv.getInstance(sparkSession).storePath
+ var storePath = CarbonEnv.getInstance(sparkSession).storePath
CarbonEnv.getInstance(sparkSession).carbonMetastore.
- checkSchemasModifiedTimeAndReloadTables(storePath)
+ checkSchemasModifiedTimeAndReloadTables()
val LOGGER =
LogServiceFactory.getLogService(this.getClass.getCanonicalName)
cm.databaseName = GetDB.getDatabaseName(cm.databaseNameOp,
sparkSession)
+ storePath = GetDB.getDatabaseLocation(cm.databaseName, sparkSession,
storePath)
--- End diff --
fixed
---
