chukwa-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From asrab...@apache.org
Subject svn commit: r830398 - in /hadoop/chukwa/trunk: CHANGES.txt src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
Date Tue, 27 Oct 2009 23:25:26 GMT
Author: asrabkin
Date: Tue Oct 27 23:25:25 2009
New Revision: 830398

URL: http://svn.apache.org/viewvc?rev=830398&view=rev
Log:
CHUKWA-407. PatternSyntaxExceptions should be sent to client. Contributed by thushara wijeratna.

Modified:
    hadoop/chukwa/trunk/CHANGES.txt
    hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java

Modified: hadoop/chukwa/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/CHANGES.txt?rev=830398&r1=830397&r2=830398&view=diff
==============================================================================
--- hadoop/chukwa/trunk/CHANGES.txt (original)
+++ hadoop/chukwa/trunk/CHANGES.txt Tue Oct 27 23:25:25 2009
@@ -150,6 +150,8 @@
 
   BUG FIXES
 
+    CHUKWA-407. PatternSyntaxExceptions should be sent to client. (thushara wijeratna via
asrabkin)
+
     CHUKWA-402. Added readme and license notice file. (asrabkin)
 
     CHUKWA-401. Fix race condition in Dir Tailing adaptor test case. (asrabkin)

Modified: hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
URL: http://svn.apache.org/viewvc/hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java?rev=830398&r1=830397&r2=830398&view=diff
==============================================================================
--- hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
(original)
+++ hadoop/chukwa/trunk/src/java/org/apache/hadoop/chukwa/datacollection/writer/SocketTeeWriter.java
Tue Oct 27 23:25:25 2009
@@ -159,6 +159,7 @@
         sock.setSoTimeout(timeout);
         sock.setKeepAlive(USE_KEEPALIVE);
         in = new BufferedReader(new InputStreamReader(sock.getInputStream()));
+        out = new DataOutputStream(sock.getOutputStream());
         String cmd = in.readLine();
         if(!cmd.contains(" ")) {
           
@@ -175,7 +176,6 @@
         
         String cmdAfterSpace = cmd.substring(cmd.indexOf(' ')+1);
         rules = new Filter(cmdAfterSpace);
-        out = new DataOutputStream(sock.getOutputStream());
 
           //now that we read everything OK we can add ourselves to list, and return.
         synchronized(tees) {



Mime
View raw message