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 31bf278ff..63a0fb205 100644
--- 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);
       }
     }