streams-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "ASF GitHub Bot (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (STREAMS-230) Broadcast Monitor doesn't start in all cases
Date Tue, 02 Dec 2014 19:12:12 GMT

    [ 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)

Mime
View raw message