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