File tree Expand file tree Collapse file tree 2 files changed +8
-13
lines changed
main/java/org/elasticsearch/cluster/coordination
test/java/org/elasticsearch/cluster/coordination Expand file tree Collapse file tree 2 files changed +8
-13
lines changed Original file line number Diff line number Diff line change @@ -674,7 +674,7 @@ public void onResponse(Releasable response) {
674
674
public void onFailure (Exception e ) {
675
675
// The failure of the first node-join publication does not imply that the join failed,
676
676
// because it may be retried and eventually succeed
677
- if (! applierState .nodes ().nodeExists (joinRequest .getSourceNode ())) {
677
+ if (applierState .nodes ().nodeExists (joinRequest .getSourceNode ()) == false ) {
678
678
logger .warn (
679
679
() -> format (
680
680
"received join request from [%s] but could not connect back to the joining node" ,
Original file line number Diff line number Diff line change @@ -1492,18 +1492,13 @@ public void testDoesNotReportConnectBackProblemsDuringJoiningIfNodeIsInClusterSt
1492
1492
1493
1493
logger .info ("--> removed [{}] but adding to master's cluster state" , partitionedNode );
1494
1494
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 ) -> {});
1507
1502
1508
1503
logger .info ("--> healing [{}] but blocking handshakes" , partitionedNode );
1509
1504
partitionedNode .heal ();
You can’t perform that action at this time.
0 commit comments