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.
---