You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by ni...@apache.org on 2017/06/30 13:58:03 UTC

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)

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 <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) {