diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java index 04e0eea..c3d1199 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/ImportSemanticAnalyzer.java @@ -250,8 +250,8 @@ public void analyzeInternal(ASTNode ast) throws SemanticException { Task t = TaskFactory.get(new DDLWork(getInputs(), getOutputs(), tblDesc), conf); - Table table = new Table(dbname, tblDesc.getTableName()); - String currentDb = SessionState.get().getCurrentDatabase(); + String[] dbTableName =Utilities.getDbTableName(dbname,tblDesc.getTableName()); + Table table = new Table(dbTableName[0], dbTableName[1]); conf.set("import.destination.dir", wh.getTablePath(db.getDatabaseCurrent(), tblDesc.getTableName()).toString());