From 23d94ed46f040616d6f7c962944ea3d4a32ed79d Mon Sep 17 00:00:00 2001 From: yuhan Date: Wed, 3 Jan 2024 14:14:32 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E4=BD=BF=E7=94=A8mysql?= =?UTF-8?q?=E5=AD=98=E5=82=A8=E6=97=A5=E5=BF=97=E7=9A=84=E6=83=85=E5=86=B5?= =?UTF-8?q?=E4=B8=8B=E6=96=87=E4=BB=B6=E6=B5=81=E6=9C=AA=E5=85=B3=E9=97=AD?= =?UTF-8?q?=E9=80=A0=E6=88=90=E7=9A=84=E6=96=87=E4=BB=B6=E6=96=87=E4=BB=B6?= =?UTF-8?q?=E5=8F=A5=E6=9F=84=E4=B8=8D=E9=87=8A=E6=94=BE=E7=9A=84bug?= =?UTF-8?q?=E3=80=82?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit (cherry picked from commit 2a9444770d227ffe46d6c700a7e8570ef3e1bc17) --- .../persistence/storage/impl/MySqlSeriesDfsService.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java index 9493f62c..4f30ba34 100644 --- a/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java +++ b/powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MySqlSeriesDfsService.java @@ -141,6 +141,7 @@ public class MySqlSeriesDfsService extends AbstractDFsService { Map meta = Maps.newHashMap(); meta.put("_server_", NetUtils.getLocalHost()); meta.put("_local_file_path_", storeRequest.getLocalFile().getAbsolutePath()); + BufferedInputStream bufferedInputStream = new BufferedInputStream(Files.newInputStream(storeRequest.getLocalFile().toPath())); Date date = new Date(System.currentTimeMillis()); @@ -153,7 +154,7 @@ public class MySqlSeriesDfsService extends AbstractDFsService { pst.setString(4, JsonUtils.toJSONString(meta)); pst.setLong(5, storeRequest.getLocalFile().length()); pst.setInt(6, SwitchableStatus.ENABLE.getV()); - pst.setBlob(7, new BufferedInputStream(Files.newInputStream(storeRequest.getLocalFile().toPath()))); + pst.setBlob(7, bufferedInputStream); pst.setString(8, null); pst.setDate(9, date); pst.setDate(10, date); @@ -165,6 +166,8 @@ public class MySqlSeriesDfsService extends AbstractDFsService { } catch (Exception e) { log.error("[MySqlSeriesDfsService] store [{}] failed!", fileLocation); ExceptionUtils.rethrow(e); + }finally { + bufferedInputStream.close(); } }