[jira] [Comment Edited] (IGNITE-21992) Data Streamer removal does not work for a new key in the same batch

["Pavel Tupitsyn (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/IGNITE-21992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17844604#comment-17844604 ] 

Pavel Tupitsyn edited comment on IGNITE-21992 at 5/8/24 9:45 AM:
-----------------------------------------------------------------

Merged to main: [dac9b46b74d2f9862a329a670519e447621ff48a|https://github.com/apache/ignite-3/commit/dac9b46b74d2f9862a329a670519e447621ff48a]


was (Author: ptupitsyn):
Merged to main: [https://github.com/apache/ignite-3/commit/dac9b46b74d2f9862a329a670519e447621ff48a|dac9b46b74d2f9862a329a670519e447621ff48a]

> 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: 40m
>  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)