mirror of
https://github.com/honeymoose/OpenSearch.git
synced 2025-03-03 09:29:11 +00:00
Fix formatting in DWSDIT#TCJDOPI
This commit is contained in:
parent
37d739a3cd
commit
97be38353a
@ -893,10 +893,10 @@ public class DiscoveryWithServiceDisruptionsIT extends ESIntegTestCase {
|
|||||||
assertNoMaster(nonMasterNode);
|
assertNoMaster(nonMasterNode);
|
||||||
|
|
||||||
logger.info("blocking cluster state publishing from master [{}] to non master [{}]", masterNode, nonMasterNode);
|
logger.info("blocking cluster state publishing from master [{}] to non master [{}]", masterNode, nonMasterNode);
|
||||||
MockTransportService masterTransportService = (MockTransportService) internalCluster().getInstance(TransportService.class,
|
MockTransportService masterTransportService =
|
||||||
masterNode);
|
(MockTransportService) internalCluster().getInstance(TransportService.class, masterNode);
|
||||||
TransportService localTransportService = internalCluster().getInstance(TransportService.class, discoveryNodes.localNode().getName
|
TransportService localTransportService =
|
||||||
());
|
internalCluster().getInstance(TransportService.class, discoveryNodes.localNode().getName());
|
||||||
if (randomBoolean()) {
|
if (randomBoolean()) {
|
||||||
masterTransportService.addFailToSendNoConnectRule(localTransportService, PublishClusterStateAction.SEND_ACTION_NAME);
|
masterTransportService.addFailToSendNoConnectRule(localTransportService, PublishClusterStateAction.SEND_ACTION_NAME);
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
x
Reference in New Issue
Block a user