fix(TDI-48431): synchronize flush resumeutil (#5553)

2022-09-01 10:07:47 +03:00
parent 72fe8689bd
commit ce75b33a11
1 changed files with 8 additions and 4 deletions
--- 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