File tree Expand file tree Collapse file tree 1 file changed +7
-12
lines changed
server/src/test/java/org/elasticsearch/cluster/coordination Expand file tree Collapse file tree 1 file changed +7
-12
lines changed Original file line number Diff line number Diff line change @@ -1492,18 +1492,13 @@ public void testDoesNotReportConnectBackProblemsDuringJoiningIfNodeIsInClusterSt
14921492
14931493 logger .info ("--> removed [{}] but adding to master's cluster state" , partitionedNode );
14941494 final ClusterNode leader = cluster .getAnyLeader ();
1495- leader .submitUpdateTask ("updating cluster state" ,
1496- cs -> {
1497- ClusterState cs2 = ClusterState .builder (cs )
1498- .nodes (DiscoveryNodes .builder (cs .nodes ())
1499- .add (partitionedNode .getLocalNode ())
1500- .build ())
1501- .build ();
1502- // Insert breakpoint here
1503- return cs2 ;
1504- },
1505- (e ) -> {}
1506- );
1495+ leader .submitUpdateTask ("updating cluster state" , cs -> {
1496+ ClusterState cs2 = ClusterState .builder (cs )
1497+ .nodes (DiscoveryNodes .builder (cs .nodes ()).add (partitionedNode .getLocalNode ()).build ())
1498+ .build ();
1499+ // Insert breakpoint here
1500+ return cs2 ;
1501+ }, (e ) -> {});
15071502
15081503 logger .info ("--> healing [{}] but blocking handshakes" , partitionedNode );
15091504 partitionedNode .heal ();
You can’t perform that action at this time.
0 commit comments