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/03/22 00:20:46 UTC
[68/71] [abbrv] git commit: not adding monitor thread,
because it freezes LocalStreamBuilderTest
not adding monitor thread, because it freezes LocalStreamBuilderTest
Project: http://git-wip-us.apache.org/repos/asf/incubator-streams/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-streams/commit/c614c6a8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-streams/tree/c614c6a8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-streams/diff/c614c6a8
Branch: refs/heads/master
Commit: c614c6a8c9e8b6a8128010b1db8a217529486edd
Parents: e3d0469
Author: Steve Blackmon <sb...@w2odigital.com>
Authored: Fri Mar 21 16:16:27 2014 -0500
Committer: Steve Blackmon <sb...@w2odigital.com>
Committed: Fri Mar 21 16:16:27 2014 -0500
----------------------------------------------------------------------
.../java/org/apache/streams/core/builders/LocalStreamBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-streams/blob/c614c6a8/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java
----------------------------------------------------------------------
diff --git a/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java b/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java
index 3fc29cc..7dd5ced 100644
--- a/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java
+++ b/streams-core/src/main/java/org/apache/streams/core/builders/LocalStreamBuilder.java
@@ -128,7 +128,7 @@ public class LocalStreamBuilder implements StreamBuilder{
Map<String, List<StreamsTask>> streamsTasks = new HashMap<String, List<StreamsTask>>();
monitorThread = new LocalStreamMonitorThread(this.executor, 1000);
try {
- this.executor.submit(monitorThread);
+ //this.executor.submit(monitorThread);
for(StreamComponent comp : this.components.values()) {
int tasks = comp.getNumTasks();
List<StreamsTask> compTasks = new LinkedList<StreamsTask>();