Repository: incubator-apex-core Updated Branches: refs/heads/devel-3 5371bc7b7 -> 50b0855d8
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/devel-3 Commit: 50b0855d840eb99d03cf8877e4b208e9a0ec85f1 Parents: 5371bc7 Author: Thomas Weise <[email protected]> Authored: Sat Jan 23 01:00:29 2016 -0800 Committer: Thomas Weise <[email protected]> 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() {
