src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java in embulk-output-jdbc-0.6.0 vs src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java in embulk-output-jdbc-0.6.1

- old
+ new

@@ -35,10 +35,12 @@ } @Override public void close() throws SQLException { - connection.close(); + if (!connection.isClosed()) { + connection.close(); + } } public String getSchemaName() { return schemaName;