[
https://issues.apache.org/jira/browse/STREAMS-230?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14231940#comment-14231940
]
ASF GitHub Bot commented on STREAMS-230:
----------------------------------------
Github user steveblackmon commented on a diff in the pull request:
https://github.com/apache/incubator-streams/pull/152#discussion_r21182611
--- Diff:
streams-runtimes/streams-runtime-local/src/main/java/org/apache/streams/local/builders/LocalStreamBuilder.java
---
@@ -316,6 +315,7 @@ protected void setupComponentTasks(Map<String,
List<StreamsTask>> streamsTasks)
this.futures.put(task, this.executor.submit(task));
compTasks.add(task);
if( comp.isOperationCountable() ) {
+ this.monitor.submit(broadcastMonitor);
--- End diff --
this PR reverts to the version that existed before merging
https://github.com/apache/incubator-streams/pull/140
we need to re-open STREAMS-230, dive a bit deeper into implications of the
issue there, and take special care that the next attempt to address the issue
does not cause any test failures, regular or sporadic.
> Broadcast Monitor doesn't start in all cases
> --------------------------------------------
>
> Key: STREAMS-230
> URL: https://issues.apache.org/jira/browse/STREAMS-230
> Project: Streams
> Issue Type: Bug
> Reporter: Steve Blackmon
> Assignee: Steve Blackmon
>
> Broadcast Monitor Thread doesn't start in all cases, specifically when there
> are no components implementing DatumStatusCountable - which doesn't need to
> be necessary.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
