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

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

Pavel Tupitsyn created IGNITE-21992:
---------------------------------------

             Summary: 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
             Fix For: 3.0.0-beta2


When remove operation follow 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)