apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [47/50] incubator-apex-core git commit: APEXCORE-60 Isolate test checkpoint directories.
Date Fri, 29 Jan 2016 07:22:06 GMT
APEXCORE-60 Isolate test checkpoint directories.


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/50b0855d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/50b0855d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/50b0855d

Branch: refs/heads/master
Commit: 50b0855d840eb99d03cf8877e4b208e9a0ec85f1
Parents: 5371bc7
Author: Thomas Weise <thomas@datatorrent.com>
Authored: Sat Jan 23 01:00:29 2016 -0800
Committer: Thomas Weise <thomas@datatorrent.com>
Committed: Sat Jan 23 01:00:29 2016 -0800

----------------------------------------------------------------------
 .../stram/plan/logical/DelayOperatorTest.java            | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/50b0855d/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
----------------------------------------------------------------------
diff --git a/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
b/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
index cb4222a..0bcc791 100644
--- a/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
+++ b/engine/src/test/java/com/datatorrent/stram/plan/logical/DelayOperatorTest.java
@@ -72,6 +72,9 @@ import static org.junit.Assert.fail;
  */
 public class DelayOperatorTest
 {
+  @Rule
+  public TestMeta testMeta = new TestMeta();
+
   private static Lock sequential = new ReentrantLock();
 
   @Before
@@ -324,7 +327,7 @@ public class DelayOperatorTest
   @Test
   public void testFibonacciRecovery1() throws Exception
   {
-    LogicalPlan dag = new LogicalPlan();
+    LogicalPlan dag = StramTestSupport.createDAG(testMeta);
 
     TestGeneratorInputOperator dummyInput = dag.addOperator("DUMMY", TestGeneratorInputOperator.class);
     FailableFibonacciOperator fib = dag.addOperator("FIB", FailableFibonacciOperator.class);
@@ -355,11 +358,10 @@ public class DelayOperatorTest
         Arrays.copyOfRange(new TreeSet<>(FibonacciOperator.results).toArray(), 0, 20));
   }
 
-  @Ignore // Out of sequence BEGIN_WINDOW tuple on Travis. Will tackle in the next version
   @Test
   public void testFibonacciRecovery2() throws Exception
   {
-    LogicalPlan dag = new LogicalPlan();
+    LogicalPlan dag = StramTestSupport.createDAG(testMeta);
 
     TestGeneratorInputOperator dummyInput = dag.addOperator("DUMMY", TestGeneratorInputOperator.class);
     FibonacciOperator fib = dag.addOperator("FIB", FibonacciOperator.class);
@@ -391,9 +393,6 @@ public class DelayOperatorTest
         Arrays.copyOfRange(new TreeSet<>(FibonacciOperator.results).toArray(), 0, 20));
   }
 
-  @Rule
-  public TestMeta testMeta = new TestMeta();
-
   @Test
   public void testCheckpointUpdate()
   {


Mime
View raw message