logerror

snowflakedb · Aug 15, 2024 · 42a23ca · 42a23ca
1 parent a929778
commit 42a23ca
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java b/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java
@@ -108,15 +108,15 @@ 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);
 
             // 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/...java/net/snowflake/ingest/streaming/internal/SnowflakeStreamingIngestChannelInternal.java b/...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();