[IGNITE-3055] IgniteDataStreamer can't be timed out

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.5.0.final
• Fix Version/s: 1.7
• Component/s: streaming
• Labels: community customer important
• Flags: Important
• Assignee: Vladislav Pyatkov
• Reporter: Valentin Kulichenko
• Created: 26/Apr/16 18:28
• Updated: 13/Jul/16 12:31
• Resolved: 13/Jul/16 12:31

Description

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.