chore: add logging when flushing data

vinted · Feb 6, 2024 · 205b80b · 205b80b
1 parent 08c3a08
commit 205b80b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java b/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java
@@ -99,8 +99,10 @@ public void close() {
 
     @Override
     public void flush(boolean endOfInput) {
+        logger.info("Flushing BigQuery writer {} data. Inflight request count {}", this.sinkInitContext.getSubtaskId(), inflightRequestCount.getRegisteredParties());
         checkAsyncException();
         inflightRequestCount.arriveAndAwaitAdvance();
+        logger.info("BigQuery writer {} data flushed. Inflight request count {}", this.sinkInitContext.getSubtaskId(), inflightRequestCount.getRegisteredParties());
     }
 
     static class AppendCallBack<A> implements ApiFutureCallback<AppendRowsResponse> {