You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 08:22:06 UTC
[47/50] incubator-apex-core git commit: APEXCORE-60 Isolate test
checkpoint directories.
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 <th...@datatorrent.com>
Authored: Sat Jan 23 01:00:29 2016 -0800
Committer: Thomas Weise <th...@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()
{