(inlong) branch master updated: [INLONG-9501][Sort] Modify EncryptFunction (#9502)

[dockerzhang]

This is an automated email from the ASF dual-hosted git repository.

dockerzhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new fa98c146ab [INLONG-9501][Sort] Modify EncryptFunction (#9502)
fa98c146ab is described below

commit fa98c146aba48894f64ab14a7a2ce61234b17adb
Author: e-mhui <111486498+e-m...@users.noreply.github.com>
AuthorDate: Wed Dec 20 19:58:46 2023 +0800

    [INLONG-9501][Sort] Modify EncryptFunction (#9502)
---
 .../main/java/org/apache/inlong/sort/function/EncryptFunction.java    | 4 ++--
 .../java/org/apache/inlong/sort/function/EncryptFunctionTest.java     | 2 +-
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git 
a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java
 
b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java
index 5612709edc..451da0f312 100644
--- 
a/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java
+++ 
b/inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java
@@ -59,10 +59,10 @@ public class EncryptFunction extends ScalarFunction {
             EncryptionType encryptionType = 
EncryptionType.getInstance(encrypt);
             switch (encryptionType) {
                 case AES:
-                    newValue = encrypt3DES(field, key);
+                    newValue = encryptAES(field, key);
                     break;
                 case DESEDE:
-                    newValue = encryptAES(field, key);
+                    newValue = encrypt3DES(field, key);
                     break;
                 default:
                     throw new 
UnsupportedOperationException(String.format("Unsupported %s encryption type", 
encrypt));
diff --git 
a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/function/EncryptFunctionTest.java
 
b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/function/EncryptFunctionTest.java
index bdf09b601f..98d686b4fb 100644
--- 
a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/function/EncryptFunctionTest.java
+++ 
b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/function/EncryptFunctionTest.java
@@ -89,7 +89,7 @@ public class EncryptFunctionTest extends AbstractTestBase {
             result.add(next);
         }
         // step 5. Whether the comparison results are as expected
-        String expect = "E102423217AE84A965937D54187A8535";
+        String expect = "/Uz8v57vMbQ=";
         Assert.assertEquals(expect, result.get(0));
     }