flume-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From arv...@apache.org
Subject svn commit: r1308221 - in /incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src: main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java
Date Sun, 01 Apr 2012 23:55:42 GMT
Author: arvind
Date: Sun Apr  1 23:55:42 2012
New Revision: 1308221

URL: http://svn.apache.org/viewvc?rev=1308221&view=rev
Log:
FLUME-1088. TestWAL.testThreadedAppend fails on jenkins build server.

(Brock Noland via Arvind Prabhakar)

Modified:
    incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java
    incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java

Modified: incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java?rev=1308221&r1=1308220&r2=1308221&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java
(original)
+++ incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/main/java/org/apache/flume/channel/recoverable/memory/wal/WAL.java
Sun Apr  1 23:55:42 2012
@@ -125,13 +125,12 @@ public class WAL<T extends Writable> imp
    * @param clazz
    * @param rollSize
    *          bytes - max size of a single file before we roll
-   * @param isRollRequiredInterval
-   *          ms - how often we check the size of a log
    * @param maxLogsSize
    *          bytes - total amount of logs to keep excluding the current log
    * @param minLogRentionPeriod
    *          ms - minimum amount of time to keep a log
    * @param workerInterval
+   *          ms - how often the background worker checks for old logs
    * @throws IOException
    */
   public WAL(File path, Class<T> clazz, long rollSize,

Modified: incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java
URL: http://svn.apache.org/viewvc/incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java?rev=1308221&r1=1308220&r2=1308221&view=diff
==============================================================================
--- incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java
(original)
+++ incubator/flume/trunk/flume-ng-channels/flume-recoverable-memory-channel/src/test/java/org/apache/flume/channel/recoverable/memory/wal/TestWAL.java
Sun Apr  1 23:55:42 2012
@@ -185,7 +185,7 @@ public class TestWAL {
       t.setDaemon(true);
       t.start();
     }
-    Assert.assertTrue(stopLatch.await(5, TimeUnit.SECONDS));
+    Assert.assertTrue(stopLatch.await(15, TimeUnit.SECONDS));
     Assert.assertEquals(Collections.EMPTY_LIST, errors);
     wal.close();
     wal = new WAL<Text>(dataDir, Text.class);



Mime
View raw message