You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streams.apache.org by sb...@apache.org on 2014/05/09 00:20:11 UTC
git commit: fixed premature-timeout
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 <sb...@w2odigital.com>
Authored: Thu May 8 17:19:45 2014 -0500
Committer: sblackmon <sb...@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) {