From 6dc7de73737be92c561c57cfb035b4c92060ba59 Mon Sep 17 00:00:00 2001
From: cgardens <charles@airbyte.io>
Date: Wed, 31 May 2023 08:20:48 -0700
Subject: [PATCH] add comment

---
 .../integrations/destination/s3/csv/CsvSerializedBuffer.java    | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/airbyte-integrations/bases/base-java-s3/src/main/java/io/airbyte/integrations/destination/s3/csv/CsvSerializedBuffer.java b/airbyte-integrations/bases/base-java-s3/src/main/java/io/airbyte/integrations/destination/s3/csv/CsvSerializedBuffer.java
index 6b831319ebe9..9cb2b2a4f719 100644
--- a/airbyte-integrations/bases/base-java-s3/src/main/java/io/airbyte/integrations/destination/s3/csv/CsvSerializedBuffer.java
+++ b/airbyte-integrations/bases/base-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 {