From ce75b33a117d2628474ab2bbde95931cab70cdeb Mon Sep 17 00:00:00 2001 From: Oleksandr Zhelezniak <66320870+ozhelezniak-talend@users.noreply.github.com> Date: Thu, 1 Sep 2022 10:07:47 +0300 Subject: [PATCH] fix(TDI-48431): synchronize flush resumeutil (#5553) --- .../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 959e6ffcae..f38d6209af 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