svn commit: r1364102 - /flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java

[jarcec]

Author: jarcec
Date: Sat Jul 21 14:11:35 2012
New Revision: 1364102

URL: http://svn.apache.org/viewvc?rev=1364102&view=rev
Log:
FLUME-1383. Improve various log messages in FileChannel and HDFSSink.

(Mike Percy via Jarek Jarcec Cecho)

Modified:
    
flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java

Modified: 
flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
URL: 
http://svn.apache.org/viewvc/flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java?rev=1364102&r1=1364101&r2=1364102&view=diff
==============================================================================
--- 
flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
 (original)
+++ 
flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
 Sat Jul 21 14:11:35 2012
@@ -339,7 +339,8 @@ public class HDFSEventSink extends Abstr
     } catch (TimeoutException eT) {
       future.cancel(true);
       sinkCounter.incrementConnectionFailedCount();
-      throw new IOException("Callable timed out", eT);
+      throw new IOException("Callable timed out after " + callTimeout + " ms",
+          eT);
     } catch (ExecutionException e1) {
       sinkCounter.incrementConnectionFailedCount();
       Throwable cause = e1.getCause();