add comment

airbytehq · May 31, 2023 · 6dc7de7 · 6dc7de7
1 parent d227a7e
commit 6dc7de7
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...java-s3/src/main/java/io/airbyte/integrations/destination/s3/csv/CsvSerializedBuffer.java b/...java-s3/src/main/java/io/airbyte/integrations/destination/s3/csv/CsvSerializedBuffer.java
@@ -66,6 +66,7 @@ protected void writeRecord(final AirbyteRecordMessage record) throws IOException
 
   @Override
   protected void flushWriter() throws IOException {
+    // in an async world, it is possible that flush writer gets called even if no records were accepted.
     if (csvPrinter != null) {
       csvPrinter.flush();
     } else {
@@ -75,6 +76,7 @@ protected void flushWriter() throws IOException {
 
   @Override
   protected void closeWriter() throws IOException {
+    // in an async world, it is possible that flush writer gets called even if no records were accepted.
     if (csvPrinter != null) {
       csvPrinter.close();
     } else {