diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java b/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java
index ed252b509..737441b2b 100644
--- a/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java
+++ b/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java
@@ -108,7 +108,7 @@ static <T> Blob constructBlobAndMetadata(
 
           // Check if encryption key is available
           if (encryptionKey == null) {
-            logger.logInfo(
+            logger.logError(
                 "Encryption key is not available for table={}, blob={}",
                 firstChannelFlushContext.getFullyQualifiedTableName(),
                 filePath);
@@ -116,7 +116,7 @@ static <T> Blob constructBlobAndMetadata(
             // Print the entire encryptionKeysPerTable Map
             for (Map.Entry<FullyQualifiedTableName, EncryptionKey> entry :
                 encryptionKeysPerTable.entrySet()) {
-              logger.logInfo("Key = " + entry.getKey() + ", Value = " + entry.getValue());
+              logger.logError("Key = " + entry.getKey() + ", Value = " + entry.getValue());
             }
           }
 
diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelInternal.java b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelInternal.java
index 3bfcc5aa6..2419a7822 100644
--- a/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelInternal.java
+++ b/src/main/java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelInternal.java
@@ -292,6 +292,7 @@ public CompletableFuture<Void> close() {
   }
 
   @Override
+  // BERZAN
   public CompletableFuture<Void> close(boolean drop) {
     checkValidation();