[ 
https://issues.apache.org/jira/browse/APEXCORE-595?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15793348#comment-15793348
 ] 

Thomas Weise commented on APEXCORE-595:
---------------------------------------

I don't think there is anything that needs to be done regarding bufferserver. 
The master should only send a valid committed windowId to the containers.

> Master incorrectly updates committedWindowId when all partitions are 
> terminated.
> --------------------------------------------------------------------------------
>
>                 Key: APEXCORE-595
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-595
>             Project: Apache Apex Core
>          Issue Type: Bug
>            Reporter: Tushar Gosavi
>            Assignee: Tushar Gosavi
>
> When all partitions are terminated application master incorrectly updates the 
> committedWindowId to Long.MAX_VALUE and send purge requet to StramChild 
> causing exception in StramChild.
> The problematic code is in StreamingContainerManager.updateCheckpoints.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to