Details
Description
Bug reproducer:
@Test public void testComputeBroadcast2() throws Exception { try (IgniteEx g0 = startGrid(0); IgniteEx g1 = startClientGrid(1)) { SystemView<ComputeTaskView> tasks = g0.context().systemView().view(TASKS_VIEW); g1.compute().broadcastAsync(() -> { try { Thread.sleep(60_000L); } catch (InterruptedException e) { throw new RuntimeException(e); } }); Thread.sleep(1_000L); assertEquals(1, tasks.size()); } }
Attachments
Issue Links
- duplicates
-
IGNITE-12745 Compute job system view
- Resolved
- links to