test using carbondata

apache · Dec 18, 2018 · 17c9986 · 17c9986
1 parent cabafe5
commit 17c9986
Showing 1 changed file with 8 additions and 2 deletions.
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,14 @@ class CarbonFileMetastore extends CarbonMetaStore {
             || name.equalsIgnoreCase("carbondata")) => name
           case _ => throw new NoSuchTableException(database, tableIdentifier.table)
         }
-        val identifier: AbsoluteTableIdentifier = AbsoluteTableIdentifier.from(
-           catalogTable.location.toString, database, tableIdentifier.table)
+        var identifier: AbsoluteTableIdentifier = null
+        if (catalogTable.storage.properties.contains("tablepath")) {
+          identifier = AbsoluteTableIdentifier.from(
+            catalogTable.storage.properties("tablepath"), database, tableIdentifier.table)
+        } else {
+          identifier = AbsoluteTableIdentifier.from(
+            catalogTable.location.toString, database, tableIdentifier.table)
+        }
         CarbonEnv.getInstance(sparkSession).carbonMetaStore.
           createCarbonRelation(catalogTable.storage.properties, identifier, sparkSession)
       case _ => throw new NoSuchTableException(database, tableIdentifier.table)