diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java index f4d0bc3698..b4d1de7fa3 100644 --- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java +++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java @@ -212,6 +212,11 @@ public StagingFileLock acquireFileLock(String serverInfo, Object... path) { StagingFileLock stagingFileLock = new StagingFileLock(); File lockFile = new File(lockFilePath); + File containingDirectory = lockFile.getParentFile(); + + if (containingDirectory != null) { + containingDirectory.mkdirs(); + } boolean acquired = false; try {