in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarConnector.java [90:101]
public final void shutdown() {
try {
this.pulsarConnectorConfig.close();
} catch (Exception e) {
log.error(e, "Failed to close pulsar connector");
}
try {
lifeCycleManager.stop();
} catch (Exception e) {
log.error(e, "Error shutting down connector");
}
}