src/main/java/org/embulk/output/postgresql/AbstractPostgreSQLCopyBatchInsert.java in embulk-output-postgresql-0.8.2 vs src/main/java/org/embulk/output/postgresql/AbstractPostgreSQLCopyBatchInsert.java in embulk-output-postgresql-0.8.3

- old
+ new

@@ -7,11 +7,10 @@ import java.io.BufferedWriter; import java.io.OutputStreamWriter; import java.io.IOException; import java.nio.charset.Charset; import java.math.BigDecimal; -import java.sql.SQLException; import org.embulk.spi.time.Timestamp; import org.embulk.output.jdbc.BatchInsert; public abstract class AbstractPostgreSQLCopyBatchInsert implements BatchInsert @@ -66,17 +65,9 @@ long fsize = currentFile.length(); if (fsize > Integer.MAX_VALUE) { return Integer.MAX_VALUE; } else { return (int) fsize; - } - } - - public void finish() throws IOException, SQLException - { - closeCurrentFile(); // this is necessary to make getBatchWeight() work - if (getBatchWeight() != 0) { - flush(); } } public void add() throws IOException {