FIxed a race condition on CopyDataPublisher.

jinglt · Jul 27, 2016 · 5854bc1 · 5854bc1
1 parent bf832dc
commit 5854bc1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../main/java/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java b/.../main/java/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriterBuilder.java
@@ -44,7 +44,7 @@ protected DataWriter<FileAwareInputStream> buildWriter() throws IOException {
    * contain job_id. This is to make sure uncleaned data from previous execution does not corrupt final published data
    * produced by this execution.
    */
-  public static void setJobSpecificOutputPaths(State state) {
+  public synchronized static void setJobSpecificOutputPaths(State state) {
 
     // Other tasks may have set this already
     if (!StringUtils.containsIgnoreCase(state.getProp(ConfigurationKeys.WRITER_STAGING_DIR),