[
https://issues.apache.org/jira/browse/IGNITE-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Pavel Tupitsyn updated IGNITE-21992:
------------------------------------
Ignite Flags: (was: Docs Required,Release Notes Required)
> Data Streamer removal does not work for a new key in the same batch
> -------------------------------------------------------------------
>
> Key: IGNITE-21992
> URL: https://issues.apache.org/jira/browse/IGNITE-21992
> Project: Ignite
> Issue Type: Bug
> Components: streaming
> Affects Versions: 3.0.0-beta1
> Reporter: Pavel Tupitsyn
> Assignee: Pavel Tupitsyn
> Priority: Major
> Labels: ignite-3
> Fix For: 3.0.0-beta2
>
> Time Spent: 10m
> Remaining Estimate: 0h
>
> When remove operation follows insert in the same batch, remove is ignored.
> See *ItAbstractDataStreamerTest#testSameItemInsertUpdateRemove*
> {code:java}
> @ParameterizedTest
> @ValueSource(ints = {1, 2, 3})
> public void testSameItemInsertUpdateRemove(int pageSize) {
> RecordView<Tuple> view = defaultTable().recordView();
> CompletableFuture<Void> streamerFut;
> int key = 333000;
> try (var publisher = new
> SubmissionPublisher<DataStreamerItem<Tuple>>()) {
> streamerFut = view.streamData(publisher,
> DataStreamerOptions.builder().pageSize(pageSize).build());
> publisher.submit(DataStreamerItem.of(tuple(key, "foo")));
> publisher.submit(DataStreamerItem.removed(tupleKey(key)));
> }
> streamerFut.orTimeout(1, TimeUnit.SECONDS).join();
> assertNull(view.get(null, tupleKey(key)));
> }
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
