浏览代码

AMBARI-18745. Logs wont display for users in Ambari hive view after job completion. (Ashween Rajeev via dipayanb)

Dipayan Bhowmick 8 年之前
父节点
当前提交
fd08e5500d

+ 2 - 3
contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/actor/LogAggregator.java

@@ -72,10 +72,9 @@ public class LogAggregator extends HiveActor {
       try {
         getMoreLogs();
       } catch (SQLException e) {
-        LOG.error("SQL Error while getting logs. Tried writing to: {}", logFile);
+        LOG.error("SQL Error while getting logs. Tried writing to: {}. Exception: {}", logFile, e);
       } catch (HdfsApiException e) {
-        LOG.warn("HDFS Error while getting writing logs to {}", logFile);
-
+        LOG.warn("HDFS Error while getting writing logs to {}. Exception: {}", logFile, e);
       }
     }
   }

+ 3 - 1
contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/internal/SafeViewContext.java

@@ -45,11 +45,13 @@ public class SafeViewContext implements ViewContext {
   private final ViewContext viewContext;
   private final String username;
   private final String loggedinUser;
+  private final Map<String, String> properties;
 
   public SafeViewContext(ViewContext viewContext) {
     this.viewContext = viewContext;
     username = viewContext.getUsername();
     loggedinUser = viewContext.getLoggedinUser();
+    properties = viewContext.getProperties();
   }
 
   @Override
@@ -89,7 +91,7 @@ public class SafeViewContext implements ViewContext {
 
   @Override
   public Map<String, String> getProperties() {
-    return viewContext.getProperties();
+    return properties;
   }
 
   @Override

+ 1 - 9
contrib/views/hive-next/src/main/java/org/apache/ambari/view/hive2/resources/jobs/JobService.java

@@ -100,7 +100,6 @@ public class JobService extends BaseService {
 
   protected final static Logger LOG =
       LoggerFactory.getLogger(JobService.class);
-  private Aggregator aggregator;
 
   protected synchronized JobResourceManager getResourceManager() {
     if (resourceManager == null) {
@@ -112,16 +111,9 @@ public class JobService extends BaseService {
 
 
   protected Aggregator getAggregator() {
-    if (aggregator == null) {
       IATSParser atsParser = getSharedObjectsFactory().getATSParser();
       ActorRef operationController = ConnectionSystem.getInstance().getOperationController(context);
-      aggregator = new Aggregator(getResourceManager(), atsParser, operationController);
-    }
-    return aggregator;
-  }
-
-  protected void setAggregator(Aggregator aggregator) {
-    this.aggregator = aggregator;
+      return new Aggregator(getResourceManager(), atsParser, operationController);
   }
 
   /**