From 4f9044eb9f412fd3abd1a32abba287618ab95e24 Mon Sep 17 00:00:00 2001
From: Christian Wulf <chw@informatik.uni-kiel.de>
Date: Thu, 6 Aug 2015 14:45:15 +0200
Subject: [PATCH] fixes #205; fixes #206
---
.../basic/distributor/dynamic/DynamicDistributorTest.java | 5 ++---
1 file changed, 2 insertions(+), 3 deletions(-)
diff --git a/src/test/java/teetime/stage/basic/distributor/dynamic/DynamicDistributorTest.java b/src/test/java/teetime/stage/basic/distributor/dynamic/DynamicDistributorTest.java
index deeb0940..26a61ce6 100644
--- a/src/test/java/teetime/stage/basic/distributor/dynamic/DynamicDistributorTest.java
+++ b/src/test/java/teetime/stage/basic/distributor/dynamic/DynamicDistributorTest.java
@@ -33,7 +33,6 @@ import teetime.stage.CollectorSink;
import teetime.stage.InitialElementProducer;
import teetime.util.framework.port.PortAction;
-//@Ignore
public class DynamicDistributorTest {
@Test
@@ -101,7 +100,7 @@ public class DynamicDistributorTest {
assertThat(config.getOutputElements(), contains(0, 1, 2, 4, 5));
assertValuesForIndex(inputActions[0], Collections.<Integer> emptyList());
- assertValuesForIndex(inputActions[2], Arrays.asList(3)); // FIXME fails sometimes
+ assertValuesForIndex(inputActions[2], Arrays.asList(3));
assertValuesForIndex(inputActions[3], Collections.<Integer> emptyList());
}
@@ -123,7 +122,7 @@ public class DynamicDistributorTest {
@SuppressWarnings("unchecked")
CollectorSink<Integer> collectorSink = (CollectorSink<Integer>) stage;
- assertThat(collectorSink.getElements(), is(values)); // FIXME fails sometimes with a ConcurrentModificationException
+ assertThat(collectorSink.getElements(), is(values));
}
private static class DynamicDistributorTestConfig<T> extends Configuration {
--
GitLab