You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@chukwa.apache.org by ey...@apache.org on 2011/08/18 07:20:38 UTC
svn commit: r1159038 - in /incubator/chukwa/trunk: ./ src/java/org/apache/hadoop/chukwa/datacollection/agent/ src/java/org/apache/hadoop/chukwa/datacollection/collector/ src/java/org/apache/hadoop/chukwa/hicc/

Author: eyang
Date: Thu Aug 18 05:20:38 2011
New Revision: 1159038

URL: http://svn.apache.org/viewvc?rev=1159038&view=rev
Log:
CHUKWA-597. Close stderr and stdout after parent process detached.  (Eric Yang)

Modified:
    incubator/chukwa/trunk/CHANGES.txt
    incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java
    incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/collector/CollectorStub.java
    incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/hicc/HiccWebServer.java

Modified: incubator/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/CHANGES.txt?rev=1159038&r1=1159037&r2=1159038&view=diff
==============================================================================
--- incubator/chukwa/trunk/CHANGES.txt (original)
+++ incubator/chukwa/trunk/CHANGES.txt Thu Aug 18 05:20:38 2011
@@ -90,6 +90,8 @@ Trunk (unreleased changes)
 
   BUG FIXES
 
+    CHUKWA-597. Close stderr and stdout after parent process detached.  (Eric Yang)
+
     CHUKWA-38.  Download Hadoop jar files from ivy.  (Eric Yang)
 
     CHUKWA-595.  Fixed buffering time calculation for Agent to send data to Collector.  (Eric Yang)

Modified: incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java?rev=1159038&r1=1159037&r2=1159038&view=diff
==============================================================================
--- incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java (original)
+++ incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/agent/ChukwaAgent.java Thu Aug 18 05:20:38 2011
@@ -190,7 +190,8 @@ public class ChukwaAgent implements Adap
       agent.connector.start();
 
       log.info("local agent started on port " + agent.getControlSock().portno);
-
+      System.out.close();
+      System.err.close();
     } catch (AlreadyRunningException e) {
       log.error("agent started already on this machine with same portno;"
           + " bailing out");

Modified: incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/collector/CollectorStub.java
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/collector/CollectorStub.java?rev=1159038&r1=1159037&r2=1159038&view=diff
==============================================================================
--- incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/collector/CollectorStub.java (original)
+++ incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/collector/CollectorStub.java Thu Aug 18 05:20:38 2011
@@ -137,7 +137,8 @@ public class CollectorStub {
       jettyServer.setStopAtShutdown(true);
 
       System.out.println("started Chukwa http collector on port " + portNum);
-
+      System.out.close();
+      System.err.close();
     } catch (Exception e) {
       e.printStackTrace();
       DaemonWatcher.bailout(-1);

Modified: incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/hicc/HiccWebServer.java
URL: http://svn.apache.org/viewvc/incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/hicc/HiccWebServer.java?rev=1159038&r1=1159037&r2=1159038&view=diff
==============================================================================
--- incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/hicc/HiccWebServer.java (original)
+++ incubator/chukwa/trunk/src/java/org/apache/hadoop/chukwa/hicc/HiccWebServer.java Thu Aug 18 05:20:38 2011
@@ -238,6 +238,8 @@ public class HiccWebServer {
   public static void main(String[] args) {
     HiccWebServer hicc = HiccWebServer.getInstance();
     hicc.start();
+    System.out.close();
+    System.err.close();
   }
 
 }