Repository: ambari Updated Branches: refs/heads/trunk ae6b74f38 -> d0f12bff5
AMBARI-21108 : Hive view 1.5 was using default DB for use statement in upload table feature. corrected it to use selected database (nitirajrathore) Project: http://git-wip-us.apache.org/repos/asf/ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/d0f12bff Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/d0f12bff Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/d0f12bff Branch: refs/heads/trunk Commit: d0f12bff5eaeac764ec9ddf282d6e9e96001dc41 Parents: ae6b74f Author: Nitiraj Singh Rathore <nitiraj.rath...@gmail.com> Authored: Fri Jun 30 19:26:55 2017 +0530 Committer: Nitiraj Singh Rathore <nitiraj.rath...@gmail.com> Committed: Fri Jun 30 19:27:28 2017 +0530 ---------------------------------------------------------------------- .../ambari/view/hive2/resources/uploads/UploadService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ambari/blob/d0f12bff/contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/uploads/UploadService.java ---------------------------------------------------------------------- diff --git a/contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/uploads/UploadService.java b/contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/uploads/UploadService.java index a979dc9..040573e 100644 --- a/contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/uploads/UploadService.java +++ b/contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/uploads/UploadService.java @@ -327,7 +327,7 @@ public class UploadService extends BaseService { String insertQuery = generateInsertFromQuery(input); LOG.info("insertQuery : {}", insertQuery); - Job job = createJob(insertQuery, "default"); + Job job = createJob(insertQuery, input.getFromDatabase()); LOG.info("Job created for insert from temp table : {}", job); return Response.ok(job).build(); } catch (WebApplicationException e) { @@ -348,7 +348,7 @@ public class UploadService extends BaseService { String deleteQuery = generateDeleteQuery(input); LOG.info("deleteQuery : {}", deleteQuery); - Job job = createJob(deleteQuery, "default"); + Job job = createJob(deleteQuery, input.getDatabase()); LOG.info("Job created for delete temp table : {} ", job); return Response.ok(job).build(); } catch (WebApplicationException e) {