From 66d691faf44d4110a501d0bd365c908bc29e0488 Mon Sep 17 00:00:00 2001 From: Mikhail Petrov Date: Tue, 30 Jan 2024 22:11:17 +0300 Subject: [PATCH] IGNITE-21399 Fixed logging of reduced cache entries for distributed operations. --- .../CacheDistributedGetLongRunningFutureDumpTest.java | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheDistributedGetLongRunningFutureDumpTest.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheDistributedGetLongRunningFutureDumpTest.java index 255230c287b08..34edb617cc3fc 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheDistributedGetLongRunningFutureDumpTest.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/CacheDistributedGetLongRunningFutureDumpTest.java @@ -93,12 +93,12 @@ public void test() throws Exception { String longRunningOps = longRunningOpsLoggedFut.get(getTestTimeout(), MILLISECONDS); - Pattern pattern = Pattern.compile("rdc=Map Reducer \\[reducedEntries=ConcurrentHashMap \\{(.+)\\}"); - Matcher matcher = pattern.matcher(longRunningOps); + Matcher reducedEntriesMatcher = Pattern.compile("rdc=Map Reducer \\[reducedEntries=ConcurrentHashMap \\{(.+)\\}") + .matcher(longRunningOps); - assertTrue(matcher.find()); + assertTrue(reducedEntriesMatcher.find()); - assertEquals(logColElementsLimit, matcher.group(1).split(", ").length); + assertEquals(logColElementsLimit, reducedEntriesMatcher.group(1).split(", ").length); spi(grid(1)).stopBlock();