This is an automated email from the ASF dual-hosted git repository. joewitt pushed a commit to branch support/nifi-1.13 in repository https://gitbox.apache.org/repos/asf/nifi.git
commit 8ad6cdbdc4a14d5b9fcd9b0d0bf2e038933fadde Author: Christian Gumpert <[email protected]> AuthorDate: Sat Jan 30 14:40:37 2021 +0100 NIFI-8119: properly free database resources when done with the processing of BLOBs Signed-off-by: Matthew Burgess <[email protected]> This closes #4791 --- .../src/main/java/org/apache/nifi/util/db/JdbcCommon.java | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db/JdbcCommon.java b/nifi-nar-bundles/nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db/JdbcCommon.java index c5e454a..c5a7a5c 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db/JdbcCommon.java +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-database-utils/src/main/java/org/apache/nifi/util/db/JdbcCommon.java @@ -287,12 +287,13 @@ public class JdbcCommon { if (blob != null) { long numChars = blob.length(); byte[] buffer = new byte[(int) numChars]; - InputStream is = blob.getBinaryStream(); - int index = 0; - int c = is.read(); - while (c >= 0) { - buffer[index++] = (byte) c; - c = is.read(); + try (InputStream is = blob.getBinaryStream()) { + int index = 0; + int c = is.read(); + while (c >= 0) { + buffer[index++] = (byte) c; + c = is.read(); + } } ByteBuffer bb = ByteBuffer.wrap(buffer); rec.put(i - 1, bb);
