enhance testMultiTopologyPollWithError dbg output this is just to understand seemingly "duplicate" log/stacktraces in the failure case. Suspect build #151 has enough info to identify the root failure issue.
Project: http://git-wip-us.apache.org/repos/asf/incubator-edgent/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-edgent/commit/ede4ab6b Tree: http://git-wip-us.apache.org/repos/asf/incubator-edgent/tree/ede4ab6b Diff: http://git-wip-us.apache.org/repos/asf/incubator-edgent/diff/ede4ab6b Branch: refs/heads/develop Commit: ede4ab6be7f61387b47678b1771536dcb1a63ad6 Parents: 52f6fb3 Author: Dale LaBossiere <dlab...@us.ibm.com> Authored: Mon Oct 30 12:01:40 2017 -0400 Committer: Dale LaBossiere <dlab...@us.ibm.com> Committed: Mon Oct 30 12:01:40 2017 -0400 ---------------------------------------------------------------------- .../test/java/org/apache/edgent/test/topology/TStreamTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-edgent/blob/ede4ab6b/api/topology/src/test/java/org/apache/edgent/test/topology/TStreamTest.java ---------------------------------------------------------------------- diff --git a/api/topology/src/test/java/org/apache/edgent/test/topology/TStreamTest.java b/api/topology/src/test/java/org/apache/edgent/test/topology/TStreamTest.java index 30e3ffb..9fae5ed 100644 --- a/api/topology/src/test/java/org/apache/edgent/test/topology/TStreamTest.java +++ b/api/topology/src/test/java/org/apache/edgent/test/topology/TStreamTest.java @@ -37,6 +37,7 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; +import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; import org.apache.edgent.topology.TSink; @@ -795,13 +796,14 @@ public abstract class TStreamTest extends TopologyAbstractTest { int executions = 4; ExecutorCompletionService<Boolean> completer = new ExecutorCompletionService<>( Executors.newFixedThreadPool(executions)); + final AtomicInteger excCnt = new AtomicInteger(); for (int i = 0; i < executions; i++) { completer.submit(() -> { Topology t = newTopology(); AtomicLong n = new AtomicLong(0); TStream<Long> s = t.poll(() -> n.incrementAndGet(), 10, TimeUnit.MILLISECONDS); // Throw on the 8th tuple - s.sink((tuple) -> { if (8 == n.get()) throw new RuntimeException("MTPWE Expected Test Exception");}); + s.sink((tuple) -> { if (8 == n.get()) throw new RuntimeException("MTPWE Expected Test Exception # "+excCnt.incrementAndGet());}); // Expect 7 tuples out of 8 Condition<Long> tc = t.getTester().tupleCount(s, 7); // complete(t, tc);
