[ https://issues.apache.org/jira/browse/IGNITE-7963?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16422240#comment-16422240 ]
Dmitriy Pavlov edited comment on IGNITE-7963 at 4/2/18 1:15 PM: ---------------------------------------------------------------- [~ilyak], are tests passing now? was (Author: dpavlov): [~ilyak], are test passing now? > Futures from DataStreamer.addData() fail to complete if DataStreamer.flush() > is never called > -------------------------------------------------------------------------------------------- > > Key: IGNITE-7963 > URL: https://issues.apache.org/jira/browse/IGNITE-7963 > Project: Ignite > Issue Type: Improvement > Components: cache > Affects Versions: 2.3 > Reporter: Ilya Kasnacheev > Assignee: Ilya Kasnacheev > Priority: Minor > Labels: usability > > DataStreamer.addData() will return futures for operation. > Thus the naive use of DataStreamer will look like this: > {code} > for (Data d : data) > futs.add(dataStreamer.addData(d)); > for (IgniteFuture f : futs) > f.get(); > dataStreamer.close(); > {code} > However, this does not work. Unless flush is called (manual or otherwisE), > futures are not being processed. This code will likely hang on f.get(). > The solution, IMHO, is to introduce dataStreamer-flushing clause in f.get(). -- This message was sent by Atlassian JIRA (v7.6.3#76005)