File tree Expand file tree Collapse file tree 1 file changed +4
-0
lines changed
server/src/test/java/org/elasticsearch/action/admin/cluster/node/tasks Expand file tree Collapse file tree 1 file changed +4
-0
lines changed Original file line number Diff line number Diff line change 6767import java .util .concurrent .ExecutionException ;
6868import java .util .concurrent .TimeUnit ;
6969import java .util .concurrent .atomic .AtomicReference ;
70+ import java .util .stream .Collectors ;
7071
7172import static org .elasticsearch .action .support .PlainActionFuture .newFuture ;
7273import static org .hamcrest .Matchers .containsString ;
@@ -307,6 +308,9 @@ public void onFailure(Exception e) {
307308
308309 // Check task counts using taskManager
309310 Map <Long , Task > localTasks = testNodes [0 ].transportService .getTaskManager ().getTasks ();
311+ logger .info ("local tasks [{}]" , localTasks .values ().stream ()
312+ .map (t -> Strings .toString (t .taskInfo (testNodes [0 ].getNodeId (), true )))
313+ .collect (Collectors .joining ("," )));
310314 assertEquals (2 , localTasks .size ()); // all node tasks + 1 coordinating task
311315 Task coordinatingTask = localTasks .get (Collections .min (localTasks .keySet ()));
312316 Task subTask = localTasks .get (Collections .max (localTasks .keySet ()));
You can’t perform that action at this time.
0 commit comments