From f0c2fad98f5959f66ea5b70088ed8769e91d6e5d Mon Sep 17 00:00:00 2001 From: case-k-git Date: Wed, 25 Aug 2021 13:20:37 +0900 Subject: [PATCH] call pageBuilder close function to release buffer --- .../main/java/org/embulk/input/jdbc/AbstractJdbcInputPlugin.java | 1 + 1 file changed, 1 insertion(+) 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