You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@edgent.apache.org by dl...@apache.org on 2017/11/02 03:21:48 UTC
[37/50] [abbrv] incubator-edgent git commit: enhance
testMultiTopologyPollWithError dbg output
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 <dl...@us.ibm.com>
Authored: Mon Oct 30 12:01:40 2017 -0400
Committer: Dale LaBossiere <dl...@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);