diff --git a/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java b/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java index 6136915c8..16f027636 100644 --- 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 failedFiles) { offsets.getContinuousOffsets(), offsets.getMissingOffsets()); if (LOGGER.isDebugEnabled()) { - LOGGER.info("{} - failed files: {}", baseLog, failedFiles); + LOGGER.info("{}, failedFiles: {}", baseLog, failedFiles); } else { LOGGER.info(baseLog); }