[ https://issues.apache.org/jira/browse/IGNITE-8462?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16493320#comment-16493320 ]
Ryabov Dmitrii commented on IGNITE-8462: ---------------------------------------- I think we shouldn't throw any exception if there was any unflushed data, because {{DataStreamerImpl.close(true)}} should cancel all existing operations and reject new operations. > 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)