diff --git a/embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java b/embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java index 606a3e56..444eb6cb 100644 --- a/embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java +++ b/embulk-input-jdbc/src/main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java @@ -515,6 +515,7 @@ public TaskReport run(TaskSource taskSource, } pageBuilder.finish(); + pageBuilder.close(); // after_select runs after pageBuilder.finish because pageBuilder.finish may fail. // TODO Output plugin's transaction might still fail. In that case, after_select is