You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by tk...@apache.org on 2026/04/20 17:29:15 UTC
(ignite) 01/01: IGNITE-28582 wip
This is an automated email from the ASF dual-hosted git repository.
tkalkirill pushed a commit to branch ignite-28582
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 6b637dba1f83b51b0bcbc0528e1693ff4ab81b1a
Author: Kirill Tkalenko <tk...@yandex.ru>
AuthorDate: Mon Apr 20 20:28:53 2026 +0300
IGNITE-28582 wip
---
.../ignite/internal/metric/JmxExporterSpiTest.java | 27 +++++++++++-----------
1 file changed, 14 insertions(+), 13 deletions(-)
diff --git a/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java b/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
index 5f3c9207036..45cb9d67615 100644
--- a/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/internal/metric/JmxExporterSpiTest.java
@@ -1068,25 +1068,26 @@ public class JmxExporterSpiTest extends AbstractExporterSpiTest {
execSvc.execute(1, new TestRunnable(latch, 3));
try {
- boolean res = waitForCondition(() -> systemView(viewName).size() == 2, 5_000);
+ assertTrue(waitForCondition(() -> systemView(viewName).size() == 2, 5_000));
- assertTrue(res);
+ Set<Integer> taskStripeIdxs = new HashSet<>();
+
+ for (Map.Entry<Object, Object> entry : systemView(viewName).entrySet()) {
+ CompositeData row = (CompositeData)entry.getValue();
- TabularDataSupport view = systemView(viewName);
+ int stripeIdx = (int)row.get("stripeIndex");
+ assertEquals(poolName + "-stripe-" + stripeIdx, row.get("threadName"));
- CompositeData row0 = view.get(new Object[] {0});
+ String desc = (String) row.get("description");
- assertEquals(0, row0.get("stripeIndex"));
- assertEquals(TestRunnable.class.getSimpleName() + '1', row0.get("description"));
- assertEquals(poolName + "-stripe-0", row0.get("threadName"));
- assertEquals(TestRunnable.class.getName(), row0.get("taskName"));
+ if (desc.contains(TestRunnable.class.getSimpleName())) {
+ assertEquals(TestRunnable.class.getName(), row.get("taskName"));
- CompositeData row1 = view.get(new Object[] {1});
+ taskStripeIdxs.add(stripeIdx);
+ }
+ }
- assertEquals(1, row1.get("stripeIndex"));
- assertEquals(TestRunnable.class.getSimpleName() + '3', row1.get("description"));
- assertEquals(poolName + "-stripe-1", row1.get("threadName"));
- assertEquals(TestRunnable.class.getName(), row1.get("taskName"));
+ assertTrue(taskStripeIdxs.toString(), taskStripeIdxs.size() >= 2);
}
finally {
latch.countDown();