@Test
public void testUnregistrationConnectionError() throws InterruptedException {

    doRegister();
    kubeExecutors.failOnMembershipUpdate(new RuntimeException("Simulated membership update error"), Integer.MAX_VALUE);
    try {
        connector.unregister(ClusterMemberGenerator::clusterMemberUnregistrationRevision).block();
        fail("Failure expected");
    } catch (Exception ignore) {
    }
    kubeExecutors.doNotFailOnMembershipUpdate();
    doUnregister();
}