List files on debug lvl

snowflakedb · Dec 10, 2024 · 6d19b6b · 6d19b6b
1 parent 30bc9f2
commit 6d19b6b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java b/src/main/java/com/snowflake/kafka/connector/internal/SnowflakeSinkServiceV1.java
@@ -1094,6 +1094,7 @@ private void purge(List<String> files) {
             files.size(),
             offsets.getContinuousOffsets(),
             offsets.getMissingOffsets());
+        LOGGER.debug("Purging files: {}", files);
         conn.purgeStage(stageName, files);
       }
     }
@@ -1108,6 +1109,7 @@ private void moveToTableStage(List<String> failedFiles) {
             failedFiles.size(),
             offsets.getContinuousOffsets(),
             offsets.getMissingOffsets());
+        LOGGER.debug("Moving failed files: {}", failedFiles);
         conn.moveToTableStage(tableName, stageName, failedFiles);
       }
     }