From a92977832be17eb4c93a6e8351935b0e368a0635 Mon Sep 17 00:00:00 2001 From: Berzan Mikaili Date: Thu, 15 Aug 2024 15:39:12 +0000 Subject: [PATCH] format --- .../streaming/internal/BlobBuilder.java | 19 ++++++++++--------- 1 file changed, 10 insertions(+), 9 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 index dc631015a..ed252b509 100644 --- a/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java +++ b/src/main/java/net/snowflake/ingest/streaming/internal/BlobBuilder.java @@ -107,17 +107,18 @@ static Blob constructBlobAndMetadata( chunkLength = paddedChunk.getSecond(); // Check if encryption key is available - if (encryptionKey == null) { - logger.logInfo( - "Encryption key is not available for table={}, blob={}", - firstChannelFlushContext.getFullyQualifiedTableName(), - filePath); + if (encryptionKey == null) { + logger.logInfo( + "Encryption key is not available for table={}, blob={}", + firstChannelFlushContext.getFullyQualifiedTableName(), + filePath); - // Print the entire encryptionKeysPerTable Map - for (Map.Entry entry : encryptionKeysPerTable.entrySet()) { - logger.logInfo("Key = " + entry.getKey() + ", Value = " + entry.getValue()); - } + // Print the entire encryptionKeysPerTable Map + for (Map.Entry entry : + encryptionKeysPerTable.entrySet()) { + logger.logInfo("Key = " + entry.getKey() + ", Value = " + entry.getValue()); } + } // Encrypt the compressed chunk data, the encryption key is derived using the key from // server with the full blob path.