apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [1/2] incubator-apex-core git commit: APEXCORE-369 - Fix timeout in AbstractReservoirTest.performanceTest
Date Tue, 01 Mar 2016 03:48:05 GMT
Repository: incubator-apex-core
Updated Branches:
  refs/heads/master 139a9cac6 -> cf4e29ea3


APEXCORE-369 - Fix timeout in AbstractReservoirTest.performanceTest


Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/36978ec6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/36978ec6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/36978ec6

Branch: refs/heads/master
Commit: 36978ec6f3c098e55b3e0c04b999112eb65393b6
Parents: 7bbb4cf
Author: Vlad Rozov <v.rozov@datatorrent.com>
Authored: Mon Feb 29 15:46:47 2016 -0800
Committer: Vlad Rozov <v.rozov@datatorrent.com>
Committed: Mon Feb 29 15:46:47 2016 -0800

----------------------------------------------------------------------
 .../datatorrent/stram/engine/AbstractReservoirTest.java   | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/36978ec6/engine/src/test/java/com/datatorrent/stram/engine/AbstractReservoirTest.java
----------------------------------------------------------------------
diff --git a/engine/src/test/java/com/datatorrent/stram/engine/AbstractReservoirTest.java
b/engine/src/test/java/com/datatorrent/stram/engine/AbstractReservoirTest.java
index 7f83036..02c11b6 100644
--- a/engine/src/test/java/com/datatorrent/stram/engine/AbstractReservoirTest.java
+++ b/engine/src/test/java/com/datatorrent/stram/engine/AbstractReservoirTest.java
@@ -121,10 +121,10 @@ public class AbstractReservoirTest
   private Object performanceTestParameters()
   {
     Object[][] performanceTestParameters = new Object[][] {
-        {null, 500},
-        {"com.datatorrent.stram.engine.AbstractReservoir$SpscArrayQueueReservoir", 500},
-        {"com.datatorrent.stram.engine.AbstractReservoir$ArrayBlockingQueueReservoir", 6000},
-        {"com.datatorrent.stram.engine.AbstractReservoir$CircularBufferReservoir", 2000}
+        {null, 1500},
+        {"com.datatorrent.stram.engine.AbstractReservoir$SpscArrayQueueReservoir", 1500},
+        {"com.datatorrent.stram.engine.AbstractReservoir$ArrayBlockingQueueReservoir", 10000},
+        {"com.datatorrent.stram.engine.AbstractReservoir$CircularBufferReservoir", 4500}
     };
     for (Object[] o : performanceTestParameters) {
       o[0] = newReservoir((String)o[0], CAPACITY);
@@ -251,7 +251,7 @@ public class AbstractReservoirTest
 
     long time = System.currentTimeMillis() - start;
     logger.debug("{}: time {}, max queue size {}", reservoir.getId(), time, maxQueueSize);
-    assertTrue("Expected to complete within " + expectedTime + "millis. Actual time " + time
+ " milis",
+    assertTrue("Expected to complete within " + expectedTime + " millis. Actual time " +
time + " millis",
         expectedTime > time);
 
   }


Mime
View raw message