[ https://issues.apache.org/jira/browse/IGNITE-8462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16519490#comment-16519490 ]
Ivan Fedotov commented on IGNITE-8462: -------------------------------------- According to [~avinogradov] corrections this ticket has a new design. It's necessary to done all futures from thread buffer in DataStreamerImpl.close(true) case. Also I implement inner class in DataStreamerImpl to make work with IgniteCacheFuture, List<DataStreamerEntry> pair easier and prevent null values. > DataStreamerImpl.close(true) should throw exception > --------------------------------------------------- > > Key: IGNITE-8462 > URL: https://issues.apache.org/jira/browse/IGNITE-8462 > Project: Ignite > Issue Type: Bug > Reporter: Ivan Fedotov > Assignee: Ivan Fedotov > Priority: Major > > DataStreamerImpl.close(true) should throw CacheException in case if there was > addition data to DataStreamerImpl. Future, returned by > DataStreamerImpl.addData() also should be done after close streamer. -- This message was sent by Atlassian JIRA (v7.6.3#76005)