code format

streamnative · Dec 17, 2024 · aeb2c91 · aeb2c91
1 parent 479f01b
commit aeb2c91
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -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;
             }