You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ambari.apache.org by db...@apache.org on 2016/03/28 21:40:26 UTC
ambari git commit: AMBARI-15530. Hive View: Execution of queries
throws 'No query to process'. (dipayanb)
Repository: ambari
Updated Branches:
refs/heads/branch-2.2 af47269e9 -> 30b7fac65
AMBARI-15530. Hive View: Execution of queries throws 'No query to process'. (dipayanb)
Project: http://git-wip-us.apache.org/repos/asf/ambari/repo
Commit: http://git-wip-us.apache.org/repos/asf/ambari/commit/30b7fac6
Tree: http://git-wip-us.apache.org/repos/asf/ambari/tree/30b7fac6
Diff: http://git-wip-us.apache.org/repos/asf/ambari/diff/30b7fac6
Branch: refs/heads/branch-2.2
Commit: 30b7fac655a63187bc8994119b3d6c4dac03519c
Parents: af47269
Author: Dipayan Bhowmick <di...@gmail.com>
Authored: Tue Mar 29 01:09:54 2016 +0530
Committer: Dipayan Bhowmick <di...@gmail.com>
Committed: Tue Mar 29 01:09:54 2016 +0530
----------------------------------------------------------------------
.../main/java/org/apache/ambari/view/hive/HiveViewImpl.java | 6 +++---
.../apache/ambari/view/hive/utils/SharedObjectsFactory.java | 2 +-
.../src/main/java/org/apache/ambari/view/utils/UserLocal.java | 2 +-
.../src/main/java/org/apache/ambari/view/utils/ViewImpl.java | 2 +-
4 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ambari/blob/30b7fac6/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java
----------------------------------------------------------------------
diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java
index f98e2b0..e28dfbf 100644
--- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java
+++ b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/HiveViewImpl.java
@@ -38,13 +38,13 @@ public class HiveViewImpl implements View {
@Override
public void onDestroy(ViewInstanceDefinition definition) {
-
+ SharedObjectsFactory.dropInstanceCache(definition.getInstanceName());
}
@Override
public void onUpdate(ViewInstanceDefinition definition) {
//drop all cached connection for instance
- UserLocal.dropInstanceConnection(definition.getInstanceName());
- SharedObjectsFactory.dropInstanceConnection(definition.getInstanceName());
+ UserLocal.dropInstanceCache(definition.getInstanceName());
+ SharedObjectsFactory.dropInstanceCache(definition.getInstanceName());
}
}
http://git-wip-us.apache.org/repos/asf/ambari/blob/30b7fac6/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/utils/SharedObjectsFactory.java
----------------------------------------------------------------------
diff --git a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/utils/SharedObjectsFactory.java b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/utils/SharedObjectsFactory.java
index 94af2fb..45f2fbf 100644
--- a/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/utils/SharedObjectsFactory.java
+++ b/contrib/views/hive/src/main/java/org/apache/ambari/view/hive/utils/SharedObjectsFactory.java
@@ -174,7 +174,7 @@ public class SharedObjectsFactory implements IStorageFactory {
*
* @param instanceName
*/
- public static void dropInstanceConnection(String instanceName){
+ public static void dropInstanceCache(String instanceName){
for(Map<String,Object> cache : localObjects.values()){
for(Iterator<Map.Entry<String, Object>> it = cache.entrySet().iterator(); it.hasNext();){
Map.Entry<String, Object> entry = it.next();
http://git-wip-us.apache.org/repos/asf/ambari/blob/30b7fac6/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/UserLocal.java
----------------------------------------------------------------------
diff --git a/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/UserLocal.java b/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/UserLocal.java
index 9d831ee..40c8e6e 100644
--- a/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/UserLocal.java
+++ b/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/UserLocal.java
@@ -134,7 +134,7 @@ public class UserLocal<T> {
*
* @param instanceName
*/
- public static void dropInstanceConnection(String instanceName){
+ public static void dropInstanceCache(String instanceName){
for(Map<String,Object> cache : viewSingletonObjects.values()){
for(Iterator<Map.Entry<String, Object>> it = cache.entrySet().iterator();it.hasNext();){
Map.Entry<String, Object> entry = it.next();
http://git-wip-us.apache.org/repos/asf/ambari/blob/30b7fac6/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ViewImpl.java
----------------------------------------------------------------------
diff --git a/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ViewImpl.java b/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ViewImpl.java
index 170e775..57f693d 100644
--- a/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ViewImpl.java
+++ b/contrib/views/utils/src/main/java/org/apache/ambari/view/utils/ViewImpl.java
@@ -45,6 +45,6 @@ public class ViewImpl implements View {
@Override
public void onUpdate(ViewInstanceDefinition definition) {
//refresh all cached connection
- UserLocal.dropInstanceConnection(definition.getInstanceName());
+ UserLocal.dropInstanceCache(definition.getInstanceName());
}
}