Merge pull request #43 from ramanenka/CXP-3032

CXP-3032: Race condition during `local.buffer.dir` creation
sugarcrm · Feb 15, 2024 · baa5e2c · baa5e2c
2 parents 5e6180d + cee8ece
commit baa5e2c
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/build.gradle b/build.gradle
@@ -13,7 +13,7 @@ allprojects {
 	apply plugin: 'maven-publish'
 
 	group = 'com.spredfast.kafka.connect.s3'
-	version = '1.2.0'
+	version = '1.2.1'
 
 	apply plugin: 'java-library'
 	sourceCompatibility = 11

diff --git a/sink/src/main/java/com/spredfast/kafka/connect/s3/sink/S3SinkTask.java b/sink/src/main/java/com/spredfast/kafka/connect/s3/sink/S3SinkTask.java
@@ -233,7 +233,11 @@ private PartitionWriter(TopicPartition tp, SinkRecord firstRecord) throws IOExce
               .orElseThrow(() -> new ConnectException("No local buffer directory configured"));
 
       File directory = new File(localBufferDirectory);
-      if (!directory.exists() && !directory.mkdirs()) {
+      int attempts = 3;
+      while (attempts > 0 && !directory.exists() && !directory.mkdirs()) {
+        attempts--;
+      }
+      if (!directory.exists()) {
         throw new ConnectException("Could not create directory " + localBufferDirectory);
       }