This is an automated email from the ASF dual-hosted git repository. ilyak pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push: new 8e5f779 IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874. 8e5f779 is described below commit 8e5f7797320a309ef84e7e9c2e9f43a94226ba30 Author: Ilya Kasnacheev <ilya.kasnach...@gmail.com> AuthorDate: Tue Jun 2 19:13:35 2020 +0300 IGNITE-5214 Prevent concurrent access to pendingEvts when debug is on - Fixes #7874. Signed-off-by: Ilya Kasnacheev <ilya.kasnach...@gmail.com> --- .../CacheContinuousQueryPartitionRecovery.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java index ac319b4..ed96727 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryPartitionRecovery.java @@ -251,15 +251,15 @@ class CacheContinuousQueryPartitionRecovery { if (skippedFiltered) pendingEvts.headMap(lastFiredEvt).clear(); } - } - if (log.isDebugEnabled()) { - log.debug("Will send to listener the following events [entries=" + entries + - ", lastFiredEvt=" + lastFiredEvt + - ", curTop=" + curTop + - ", entUpdCnt=" + entry.updateCounter() + - ", partId=" + entry.partition() + - ", pendingEvts=" + pendingEvts + ']'); + if (log.isDebugEnabled()) { + log.debug("Will send to listener the following events [entries=" + entries + + ", lastFiredEvt=" + lastFiredEvt + + ", curTop=" + curTop + + ", entUpdCnt=" + entry.updateCounter() + + ", partId=" + entry.partition() + + ", pendingEvts=" + pendingEvts + ']'); + } } return entries;