flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject svn commit: r1364102 - /flume/trunk/flume-ng-sinks/flume-hdfs-sink/src/main/java/org/apache/flume/sink/hdfs/HDFSEventSink.java
Date Sat, 21 Jul 2012 14:11:35 GMT
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();



Mime
View raw message