You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by lp...@apache.org on 2017/07/04 16:18:47 UTC
[24/36] ambari git commit: AMBARI-21108 : Hive view 1.5 was using
default DB for use statement in upload table feature. corrected it to use
selected database (nitirajrathore)
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/feature-branch-AMBARI-21307
Commit: d0f12bff5eaeac764ec9ddf282d6e9e96001dc41
Parents: ae6b74f
Author: Nitiraj Singh Rathore <ni...@gmail.com>
Authored: Fri Jun 30 19:26:55 2017 +0530
Committer: Nitiraj Singh Rathore <ni...@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) {