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
---