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

Denis Magda commented on IGNITE-3055:
-------------------------------------

Vlad, thanks! I've reviewed and provided final minor comments from my side.

However, since you've updated the public API please send an email to the dev 
list getting a final approve from the community. Mention that you have added 
{{timeout}} method to the data streamer interface and {{TimeoutException}}.

> IgniteDataStreamer can't be timed out
> -------------------------------------
>
>                 Key: IGNITE-3055
>                 URL: https://issues.apache.org/jira/browse/IGNITE-3055
>             Project: Ignite
>          Issue Type: Bug
>          Components: streaming
>    Affects Versions: 1.5.0.final
>            Reporter: Valentin Kulichenko
>            Assignee: Vladislav Pyatkov
>            Priority: Critical
>              Labels: community, customer, important
>             Fix For: 1.7
>
>
> In current implementation there is no way to timeout the data streamer. 
> Specifically, {{addData()}} can hang on the parallel operations semaphore and 
> {{close()}} can infinitely wait on one of the futures to complete.
> We should introduce the configurable timeout and fail any data streamer 
> operation if it's exceeded.



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

Reply via email to