From d47cb925a16cc6b46f91c9bd6c29d4a0304bb660 Mon Sep 17 00:00:00 2001 From: Oleksandr Zhelezniak <66320870+ozhelezniak-talend@users.noreply.github.com> Date: Thu, 1 Sep 2022 10:08:10 +0300 Subject: [PATCH] fix(TDI-48431): synchronize flush resumeutil (#5551) --- .../resources/java/routines/system/ResumeUtil.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/main/plugins/org.talend.librariesmanager/resources/java/routines/system/ResumeUtil.java b/main/plugins/org.talend.librariesmanager/resources/java/routines/system/ResumeUtil.java index a214491e12..1864f0a780 100644 --- a/main/plugins/org.talend.librariesmanager/resources/java/routines/system/ResumeUtil.java +++ b/main/plugins/org.talend.librariesmanager/resources/java/routines/system/ResumeUtil.java @@ -193,11 +193,15 @@ public class ResumeUtil { } } } - + public void flush() { - if(csvWriter != null) { - csvWriter.flush(true); - } + if (csvWriter == null) { + return; + } + + synchronized (csvWriter) { + csvWriter.flush(true); + } } // Util: invoke target check point