Github user d2r commented on a diff in the pull request:
https://github.com/apache/storm/pull/2890#discussion_r227036635
--- Diff:
integration-test/src/main/java/org/apache/storm/st/topology/TestableTopology.java
---
@@ -17,14 +17,18 @@
package org.apache.storm.st.topology;
+import java.util.concurrent.TimeUnit;
import org.apache.storm.generated.StormTopology;
public interface TestableTopology {
String DUMMY_FIELD = "dummy";
- //Some tests rely on reading the worker log. If emits are too close
together and too much is logged, the log might roll, breaking the test.
- int MIN_SLEEP_BETWEEN_EMITS_MS = 10;
- int MAX_SLEEP_BETWEEN_EMITS_MS = 100;
+ int TIMEDATA_SLEEP_BETWEEN_EMITS_MS = 20;
+ //Some tests rely on reading the worker log. If there are too many
emits and too much is logged, the log might roll, breaking the test.
--- End diff --
OK, I assumed there was a way for the test itself to manipulate this. If
not, then no worries.
---
