|
34 | 34 | import org.opensearch.threadpool.ThreadPool;
|
35 | 35 | import org.opensearch.transport.RemoteClusterConnectionTests;
|
36 | 36 | import org.opensearch.transport.Transport;
|
37 |
| -import org.junit.Before; |
38 | 37 | import org.opensearch.transport.TransportService;
|
| 38 | +import org.junit.Before; |
39 | 39 |
|
40 | 40 | import java.util.ArrayList;
|
41 | 41 | import java.util.Arrays;
|
@@ -268,19 +268,14 @@ public void testDeleteAllPITSuccessWhenNoPITsExist() throws InterruptedException
|
268 | 268 | ActionFilters actionFilters = mock(ActionFilters.class);
|
269 | 269 | when(actionFilters.filters()).thenReturn(new ActionFilter[0]);
|
270 | 270 | List<DiscoveryNode> knownNodes = new CopyOnWriteArrayList<>();
|
271 |
| - try ( |
272 |
| - MockTransportService cluster1Transport = startTransport("cluster_1_node", knownNodes, Version.CURRENT) |
273 |
| - ) { |
| 271 | + try (MockTransportService cluster1Transport = startTransport("cluster_1_node", knownNodes, Version.CURRENT)) { |
274 | 272 | knownNodes.add(cluster1Transport.getLocalDiscoNode());
|
275 | 273 | TransportService mockTransportService = mock(TransportService.class);
|
276 | 274 | PitService pitService = new PitService(clusterServiceMock, mock(SearchTransportService.class), mockTransportService, client) {
|
277 | 275 | @Override
|
278 | 276 | public void getAllPits(ActionListener<GetAllPitNodesResponse> getAllPitsListener) {
|
279 | 277 | List<ListPitInfo> list = new ArrayList<>();
|
280 |
| - GetAllPitNodeResponse getAllPitNodeResponse = new GetAllPitNodeResponse( |
281 |
| - cluster1Transport.getLocalDiscoNode(), |
282 |
| - list |
283 |
| - ); |
| 278 | + GetAllPitNodeResponse getAllPitNodeResponse = new GetAllPitNodeResponse(cluster1Transport.getLocalDiscoNode(), list); |
284 | 279 | List<GetAllPitNodeResponse> nodeList = new ArrayList();
|
285 | 280 | nodeList.add(getAllPitNodeResponse);
|
286 | 281 | getAllPitsListener.onResponse(new GetAllPitNodesResponse(new ClusterName("cn"), nodeList, new ArrayList()));
|
|
0 commit comments