[ https://issues.apache.org/jira/browse/IGNITE-21713?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17825148#comment-17825148 ]
Ignite TC Bot commented on IGNITE-21713: ---------------------------------------- {panel:title=Branch: [pull/11269/head] Base: [master] : No blockers found!|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1}{panel} {panel:title=Branch: [pull/11269/head] Base: [master] : New Tests (4)|borderStyle=dashed|borderColor=#ccc|titleBGColor=#D6F7C1} {color:#00008b}Continuous Query 1{color} [[tests 4|https://ci2.ignite.apache.org/viewLog.html?buildId=7777543]] * {color:#013220}IgniteCacheQuerySelfTestSuite3: CacheContinuousQueryCounterReplicatedTxTest.testDataStreamerItemsReordered - PASSED{color} * {color:#013220}IgniteCacheQuerySelfTestSuite3: CacheContinuousQueryCounterPartitionedAtomicTest.testDataStreamerItemsReordered - PASSED{color} * {color:#013220}IgniteCacheQuerySelfTestSuite3: CacheContinuousQueryCounterReplicatedAtomicTest.testDataStreamerItemsReordered - PASSED{color} * {color:#013220}IgniteCacheQuerySelfTestSuite3: CacheContinuousQueryCounterPartitionedTxTest.testDataStreamerItemsReordered - PASSED{color} {panel} [TeamCity *--> Run :: All* Results|https://ci2.ignite.apache.org/viewLog.html?buildId=7777614&buildTypeId=IgniteTests24Java8_RunAll] > Data streamer doesn't fire all the CQ events > -------------------------------------------- > > Key: IGNITE-21713 > URL: https://issues.apache.org/jira/browse/IGNITE-21713 > Project: Ignite > Issue Type: Bug > Components: general > Affects Versions: 2.16 > Reporter: Evgeny Stanilovsky > Assignee: Evgeny Stanilovsky > Priority: Major > Fix For: 2.17 > > Attachments: ExampleNodeStartup.java > > Time Spent: 10m > Remaining Estimate: 0h > > Not all events are triggered through *setLocalListener* if data is pushed > through data streamer (test attached). > Steps to reproduce: > 1. start node > 2. call qry.setLocalListener with events counting > 3. register listener : cache.query(qry); > 4. put data using data streamer > 5. flush streamer and wait for all related futures > expect : all events are triggered > got: partially events are missed -- This message was sent by Atlassian Jira (v8.20.10#820010)