diff --git a/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java b/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
index 72dca558..6ecab137 100644
--- a/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
+++ b/src/main/java/org/apache/pulsar/io/jcloud/sink/BlobStoreAbstractSink.java
@@ -308,7 +308,7 @@ private void unsafeFlush() {
                 }
             } catch (Exception e) {
                 log.error("Failed to generate file path", e);
-                bulkHandleFailedRecords(e,singleTopicRecordsToInsert);
+                bulkHandleFailedRecords(e, singleTopicRecordsToInsert);
                 return;
             }