|
|
@@ -654,7 +654,9 @@ public class SnapshotResiliencyTests extends ESTestCase {
|
|
|
}
|
|
|
|
|
|
private static ClusterState stateForNode(ClusterState state, DiscoveryNode node) {
|
|
|
- return ClusterState.builder(state).nodes(DiscoveryNodes.builder(state.nodes()).localNodeId(node.getId())).build();
|
|
|
+ // Remove and add back local node to update ephemeral id on restarts
|
|
|
+ return ClusterState.builder(state).nodes(DiscoveryNodes.builder(
|
|
|
+ state.nodes()).remove(node.getId()).add(node).localNodeId(node.getId())).build();
|
|
|
}
|
|
|
|
|
|
private final class TestClusterNodes {
|