Major Description
Thread shutdownThread = new Thread("Shutdown-Thread") {
@Override
public void run() {
LOG.info("Before call to shutdown master");
try {
try (Connection connection =
ConnectionFactory.createConnection(util.getConfiguration())) {
try (Admin admin = connection.getAdmin()) {
admin.shutdown();
}
}
LOG.info("After call to shutdown master");
cluster.waitOnMaster(MASTER_INDEX);
} catch (Exception e) {
}
}
};
In the output for a failed running, we only have 'Before call to shutdown master' but no 'After call to shutdown master', so I think there must be something wrong when calling admin.shutdown, but in the catch block below we just ignore the exception.