ignite-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Ilya Kasnacheev (JIRA)" <j...@apache.org>
Subject [jira] [Created] (IGNITE-7963) Futures from DataStreamer.addData() fail to complete if DataStreamer.flush() is never called
Date Thu, 15 Mar 2018 10:25:00 GMT
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)

Mime
View raw message