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