From 7b67b9c0ef10929ff486b68559dfc3e0585f1eb8 Mon Sep 17 00:00:00 2001 From: Sushant Mane Date: Thu, 4 Jan 2024 12:07:56 -0800 Subject: [PATCH] [vpj][controller][server] Change log level from INFO to DEBUG in VW::endSegment to reduce spamming (#812) --- .../main/java/com/linkedin/venice/writer/VeniceWriter.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java b/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java index 58e5c93739..5bf4a98315 100644 --- a/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java +++ b/internal/venice-common/src/main/java/com/linkedin/venice/writer/VeniceWriter.java @@ -1950,11 +1950,11 @@ public void endSegment(int partition, boolean finalSegment) { synchronized (this.partitionLocks[partition]) { Segment currentSegment = segments[partition]; if (currentSegment == null) { - logger.info("endSegment(partition {}) called but currentSegment == null. Ignoring.", partition); + logger.debug("endSegment(partition {}) called but currentSegment == null. Ignoring.", partition); } else if (!currentSegment.isStarted()) { - logger.info("endSegment(partition {}) called but currentSegment.started == false. Ignoring.", partition); + logger.debug("endSegment(partition {}) called but currentSegment.started == false. Ignoring.", partition); } else if (currentSegment.isEnded()) { - logger.info("endSegment(partition {}) called but currentSegment.ended == true. Ignoring.", partition); + logger.debug("endSegment(partition {}) called but currentSegment.ended == true. Ignoring.", partition); } else { try { sendEndOfSegment(