fix log message

apache · Jan 6, 2025 · 1db6f5b · 1db6f5b
1 parent 6a3f450
commit 1db6f5b
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...e/src/main/java/org/apache/inlong/sort/base/dirty/sink/sdk/InlongSdkDirtySinkFactory.java b/...e/src/main/java/org/apache/inlong/sort/base/dirty/sink/sdk/InlongSdkDirtySinkFactory.java
@@ -120,15 +120,15 @@ private InlongSdkDirtyOptions getOptions(ReadableConfig config) {
                 .build();
     }
 
-    private String decrypt(String before, String key) {
+    private String decrypt(String encrypted, String key) {
         String decrypted = null;
 
         try {
-            byte[] bytes = AESUtils.parseHexStr2Byte(before);
+            byte[] bytes = AESUtils.parseHexStr2Byte(encrypted);
             bytes = AESUtils.decrypt(bytes, key.trim().getBytes(StandardCharsets.UTF_8));
             decrypted = new String(Base64.decodeBase64(bytes), StandardCharsets.UTF_8);
         } catch (Throwable t) {
-            log.warn("failed to decrypt {} into cmk", before, t);
+            log.warn("failed to decrypt {} with key {}", encrypted, key, t);
             throw new RuntimeException(t);
         }
         return decrypted;