From 6d19b6b89be7508d07bdd887b88f34861314c9c9 Mon Sep 17 00:00:00 2001
From: Wojciech Trefon <wojciech.trefon@snowflake.com>
Date: Tue, 10 Dec 2024 14:40:56 +0100
Subject: [PATCH] List files on debug lvl

---
 .../kafka/connector/internal/SnowflakeSinkServiceV1.java        | 2 ++
 1 file changed, 2 insertions(+)

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);
       }
     }