Skip to content

Commit

Permalink
IGNITE-21399 Fixed logging of reduced cache entries for distributed o…
Browse files Browse the repository at this point in the history
…perations.
  • Loading branch information
petrov-mg committed Jan 30, 2024
1 parent 6f9fd48 commit 66d691f
Showing 1 changed file with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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();

Expand Down

0 comments on commit 66d691f

Please sign in to comment.