@Override
    public synchronized Set<InternalNode> getCatalogServers()
    {
        return catalogServers;
    }
@Test
    public void testGetCatalogServers()
    {
        DiscoveryNodeManager manager = new DiscoveryNodeManager(selector, workerNodeInfo, new NoOpFailureDetector(), Optional.of(host -> false), expectedVersion, testHttpClient, new TestingDriftClient<>(), internalCommunicationConfig);
        try {
            assertEquals(manager.getCatalogServers(), ImmutableSet.of(catalogServer));
        }
        finally {
            manager.stop();
        }
    }