in flink-connector-jdbc/src/main/java/org/apache/flink/connector/jdbc/xa/XaFacadePoolingImpl.java [124:134]
public void close() throws Exception {
for (XaFacade facade : mappedToXids.values()) {
facade.close();
}
for (XaFacade facade : pooled) {
facade.close();
}
if (active != null && active.isOpen()) {
active.close();
}
}