[jira] [Commented] (APEXCORE-222) Delegate Buffer Server purge to StreamingContainer

["Sandesh (JIRA)" <ji...@apache.org>]

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

Sandesh commented on APEXCORE-222:
----------------------------------

Here is the change for fixing this issue,

https://github.com/apache/apex-core/pull/350

2 more things can be done,

1. Purge the checkpoints from the Containers rather than in the Stram
2. Remove the API used by Stram to purge the data from the BufferServer.

[~thw] please let me know your thoughts on this.




> Delegate Buffer Server purge to StreamingContainer
> --------------------------------------------------
>
>                 Key: APEXCORE-222
>                 URL: https://issues.apache.org/jira/browse/APEXCORE-222
>             Project: Apache Apex Core
>          Issue Type: Improvement
>            Reporter: Thomas Weise
>            Assignee: Sandesh
>
> Currently the purge requests are sent to the buffer servers from the app master. This interaction exists parallel to the heartbeat protocol. Instead, the committed window ID that is propagated through the heartbeat response can be used in StreamingContainer to initiate the purge with the local buffer server, similar to how the committed callback on the operator occurs.



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