[jira] [Created] (IGNITE-7963) Futures from DataStreamer.addData() fail to complete if DataStreamer.flush() is never called

["Ilya Kasnacheev (JIRA)" <ji...@apache.org>]

Ilya Kasnacheev created IGNITE-7963:
---------------------------------------

             Summary: 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: Task
          Components: cache
    Affects Versions: 2.3
            Reporter: Ilya Kasnacheev
            Assignee: Ilya Kasnacheev


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)