[ https://issues.apache.org/jira/browse/IGNITE-20665?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Grigory Domozhirov updated IGNITE-20665: ---------------------------------------- Summary: DataStreamer: keep order for entries with equal keys / update such entries locally (was: DataStreamer: keep order for entries with equal keys / replace values before streaming) > DataStreamer: keep order for entries with equal keys / update such entries > locally > ---------------------------------------------------------------------------------- > > Key: IGNITE-20665 > URL: https://issues.apache.org/jira/browse/IGNITE-20665 > Project: Ignite > Issue Type: Improvement > Components: streaming > Affects Versions: 2.15 > Reporter: Grigory Domozhirov > Priority: Minor > > Code below returns "old value": > {code:java} > try ( > Ignite ignite = Ignition.start(); > IgniteCache<Integer, String> cache = ignite.createCache("test"); > IgniteDataStreamer<Integer, String> dataStreamer = > ignite.dataStreamer(cache.getName())) { > dataStreamer.allowOverwrite(true); > for (int i = 0; i < 1000; i++) { > dataStreamer.addData(0, "old value"); > } > dataStreamer.addData(0, "new value"); > dataStreamer.flush(); > System.out.println(cache.get(0)); > } > {code} > Despite streaming order is not guaranteed by DataStreamer such behaviour > might be surprising and effectively voids allowOverwrite option. > Also, it ends up with a lot of outdated entries streamed, decreasing overall > loading process. -- This message was sent by Atlassian Jira (v8.20.10#820010)