Hello!
We have a test for this in our code base,
org.apache.ignite.internal.processors.datastreamer.DataStreamProcessorSelfTest#testFlushTimeout
It passes in 2.8.
Do you have a reproducer where you don't see EVT_CACHE_OBJECT_PUT for cache
populated by data streamer with allowOverride(true)? Can
Hi Ilya - I have tried that but not firing the event. But it does fire for
put and putAll
Thanx and Regards,
KR Kumar
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Hello!
Does this change if you set allowOverride(true) on Data Streamer?
Regards,
--
Ilya Kasnacheev
чт, 30 апр. 2020 г. в 16:29, krkumar24061...@gmail.com <
krkumar24061...@gmail.com>:
> Hi Guys - When I am adding entries into cache through DataStreamer.addData,
> does it invoke the event
Hi Guys - When I am adding entries into cache through DataStreamer.addData,
does it invoke the event listeners configured for EVT_CACHE_ENTRY_CREATED,
EventType.EVT_CACHE_OBJECT_PUT??
I am configuring a local listener in the following way
engine.events().localListen(cacheChangeHandler,