flush() guarantees completion of all futures returned by addData(Object, Object) https://ignite.apache.org/releases/latest/javadoc/org/apache/ignite/IgniteDataStreamer.html#flush--
flush() will send the batch, but it is still possible for the server to crash before the message reaches it. If you need verify whether the particular put actually made it to the server, appropriate events are available. use these events: https://ignite.apache.org/docs/latest/events/events#cache-events You can put in retry logic if the client has disconnected. One possibility is to use the CacheException as per the contract of the flush() method you will get something like this: javax.cache.CacheException: class org.apache.ignite.IgniteClientDisconnectedException: Data streamer has been closed, client node disconnected. at org.apache.ignite.internal.processors.cache.GridCacheUtils.convertToCacheException(GridCacheUtils.java:1275) at org.apache.ignite.internal.processors.datastreamer.DataStreamerImpl.doFlush(DataStreamerImpl.java:1204) -- Sent from: http://apache-ignite-users.70518.x6.nabble.com/
