From 0afefe59a85cf697f785fd149a22d824092baac3 Mon Sep 17 00:00:00 2001
From: gintarasm <gintaras.matulas@gmail.com>
Date: Thu, 8 Feb 2024 11:22:17 +0200
Subject: [PATCH] chore: change flush log level to debug

---
 .../sink/defaultStream/BigQueryDefaultSinkWriter.java         | 4 ++--
 1 file changed, 2 insertions(+), 2 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
index fe9763d..5f53a3f 100644
--- a/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java
+++ b/src/main/java/com/vinted/flink/bigquery/sink/defaultStream/BigQueryDefaultSinkWriter.java
@@ -96,10 +96,10 @@ public void close() {
 
     @Override
     public void flush(boolean endOfInput) {
-        logger.info("Flushing BigQuery writer {} data. Inflight request count {}", this.sinkInitContext.getSubtaskId(), inflightRequestCount.getRegisteredParties());
+        logger.debug("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());
+        logger.debug("BigQuery writer {} data flushed. Inflight request count {}", this.sinkInitContext.getSubtaskId(), inflightRequestCount.getRegisteredParties());
     }
 
     static class AppendCallBack<A> implements ApiFutureCallback<AppendRowsResponse> {