Merge 0428249 into 96cc1a6

apache · Dec 19, 2018 · 9d377e8 · 9d377e8
2 parents 96cc1a6 + 0428249
commit 9d377e8
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonFileMetastore.scala b/integration/spark2/src/main/scala/org/apache/spark/sql/hive/CarbonFileMetastore.scala
@@ -167,8 +167,11 @@ class CarbonFileMetastore extends CarbonMetaStore {
             || name.equalsIgnoreCase("carbondata")) => name
           case _ => throw new NoSuchTableException(database, tableIdentifier.table)
         }
+        val path = catalogTable.storage.properties.collect {
+          case property if property._1.equalsIgnoreCase("tablepath") => property._2
+        }
         val identifier: AbsoluteTableIdentifier = AbsoluteTableIdentifier.from(
-           catalogTable.location.toString, database, tableIdentifier.table)
+          path.head, database, tableIdentifier.table)
         CarbonEnv.getInstance(sparkSession).carbonMetaStore.
           createCarbonRelation(catalogTable.storage.properties, identifier, sparkSession)
       case _ => throw new NoSuchTableException(database, tableIdentifier.table)