@Override
    public InternalNode getCurrentNode()
    {
        return currentNode;
    }
@Test
    public void testGetCurrentNode()
    {
        DiscoveryNodeManager manager = new DiscoveryNodeManager(selector, workerNodeInfo, new NoOpFailureDetector(), Optional.empty(), expectedVersion, testHttpClient, new TestingDriftClient<>(), internalCommunicationConfig);
        try {
            assertEquals(manager.getCurrentNode(), workerNode1);
        }
        finally {
            manager.stop();
        }
    }