Merge pull request #17 from vinted/chore/change-flush-log-level

chore: change flush log level to debug
vinted · Feb 8, 2024 · f562e73 · f562e73
2 parents 32df104 + 0afefe5
commit f562e73
Showing 1 changed file with 2 additions and 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
@@ -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> {