Repository: incubator-streams Updated Branches: refs/heads/streamstutorial c59ab10ed -> 87bd8a3f8
fixed premature-timeout Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/87bd8a3f Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/87bd8a3f Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/87bd8a3f Branch: refs/heads/streamstutorial Commit: 87bd8a3f874e711933b4e9c0a5e20518c9ff6f79 Parents: c59ab10 Author: sblackmon <sblack...@w2odigital.com> Authored: Thu May 8 17:19:45 2014 -0500 Committer: sblackmon <sblack...@w2odigital.com> Committed: Thu May 8 17:19:45 2014 -0500 ---------------------------------------------------------------------- .../java/org/apache/streams/local/tasks/StreamsProviderTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/87bd8a3f/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java ---------------------------------------------------------------------- diff --git a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java index cd43d44..cc4844c 100644 --- a/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java +++ b/streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/tasks/StreamsProviderTask.java @@ -130,7 +130,8 @@ public class StreamsProviderTask extends BaseStreamsTask implements DatumStatusC zeros = 0; } flushResults(resultSet); - if( zeros > (timeout / DEFAULT_SLEEP_TIME_MS)) + // the way this works needs to change... + if( zeros > (timeout)) this.keepRunning.set(false); Thread.sleep(DEFAULT_SLEEP_TIME_MS); } catch (InterruptedException e) {
