One more log fix

snowflakedb · Dec 11, 2024 · 090eed5 · 090eed5
1 parent 23c8585
commit 090eed5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java b/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java
@@ -1111,7 +1111,7 @@ private void moveToTableStage(List<String> failedFiles) {
                 offsets.getContinuousOffsets(),
                 offsets.getMissingOffsets());
         if (LOGGER.isDebugEnabled()) {
-          LOGGER.info("{} - {}", baseLog, failedFiles);
+          LOGGER.info("{} - failed files: {}", baseLog, failedFiles);
         } else {
           LOGGER.info(baseLog);
         }