in flink-vvp-connector-adbpg/src/main/java/org/apache/flink/connector/jdbc/table/sink/AdbpgOutputFormat.java [1073:1095]
private void closeConnection() {
try {
LOG.info("Close connection ");
if (statement != null) {
statement.close();
statement = null;
LOG.info("statement closed ");
}
if (connection != null) {
if (!connection.isClosed()) {
connection.close();
LOG.info("connection closed and discarded ");
}
connection = null;
}
} catch (SQLException e) {
LOG.error("error during closeConnection");
throw new RuntimeException(e);
} finally {
statement = null;
connection = null;
}
}