[Bug][Transform]fix custom udf throw exception

Author: hawk9821

seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/util/ContainerUtil.java

@@ -221,20 +221,6 @@ public static void copySeaTunnelStarterToContainer(
                 MountableFile.forHostPath(transformUdfJarPath),
                 Paths.get(seatunnelHomeInContainer, "lib", transformUdfJar).toString());
 
-        // copy transform-udf
-        String transformUdfJar = "seatunnel-transforms-v2-udf.jar";
-        Path transformUdfJarPath =
-                Paths.get(
-                        PROJECT_ROOT_PATH,
-                        "seatunnel-e2e",
-                        "seatunnel-transforms-v2-e2e",
-                        "seatunnel-transforms-v2-udf",
-                        "target",
-                        transformUdfJar);
-        container.withCopyFileToContainer(
-                MountableFile.forHostPath(transformUdfJarPath),
-                Paths.get(seatunnelHomeInContainer, "lib", transformUdfJar).toString());
-
         // copy bin
         final String startBinPath = startModulePath + File.separator + "src/main/bin/";
         checkPathExist(startBinPath);

seatunnel-e2e/seatunnel-transforms-v2-e2e/seatunnel-transforms-v2-udf/src/main/java/org/apache/seatunnel/e2e/transform/udf/ExampleUdf.java

@@ -19,7 +19,7 @@
 
 import org.apache.seatunnel.api.table.type.BasicType;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
-import org.apache.seatunnel.transform.sql.zeta.ZetaUDF;
+import org.apache.seatunnel.transform.sql.zeta.functions.udf.ZetaUDF;
 
 import com.google.auto.service.AutoService;
 

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLEngine.java

@@ -22,10 +22,10 @@
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
-import org.apache.seatunnel.api.transform.sql.ZetaUDF;
 import org.apache.seatunnel.common.exception.CommonErrorCodeDeprecated;
 import org.apache.seatunnel.transform.exception.TransformException;
 import org.apache.seatunnel.transform.sql.SQLEngine;
+import org.apache.seatunnel.transform.sql.zeta.functions.udf.ZetaUDF;
 
 import org.apache.commons.collections4.CollectionUtils;
 

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java

@@ -25,7 +25,6 @@
 import org.apache.seatunnel.api.table.type.SeaTunnelRow;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
 import org.apache.seatunnel.api.table.type.SqlType;
-import org.apache.seatunnel.api.transform.sql.ZetaUDF;
 import org.apache.seatunnel.common.exception.CommonErrorCodeDeprecated;
 import org.apache.seatunnel.common.exception.SeaTunnelRuntimeException;
 import org.apache.seatunnel.transform.exception.TransformException;
@@ -34,6 +33,7 @@
 import org.apache.seatunnel.transform.sql.zeta.functions.NumericFunction;
 import org.apache.seatunnel.transform.sql.zeta.functions.StringFunction;
 import org.apache.seatunnel.transform.sql.zeta.functions.SystemFunction;
+import org.apache.seatunnel.transform.sql.zeta.functions.udf.ZetaUDF;
 
 import org.apache.commons.lang3.ArrayUtils;
 import org.apache.commons.lang3.tuple.Pair;

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLType.java

@@ -26,10 +26,10 @@
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
 import org.apache.seatunnel.api.table.type.SeaTunnelRowType;
 import org.apache.seatunnel.api.table.type.SqlType;
-import org.apache.seatunnel.api.transform.sql.ZetaUDF;
 import org.apache.seatunnel.common.exception.CommonErrorCodeDeprecated;
 import org.apache.seatunnel.transform.exception.TransformException;
 import org.apache.seatunnel.transform.sql.zeta.functions.ArrayFunction;
+import org.apache.seatunnel.transform.sql.zeta.functions.udf.ZetaUDF;
 
 import org.apache.commons.collections4.CollectionUtils;
 

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/udf/DesDecrypt.java

@@ -19,7 +19,6 @@
 
 import org.apache.seatunnel.api.table.type.BasicType;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
-import org.apache.seatunnel.api.transform.sql.ZetaUDF;
 
 import com.google.auto.service.AutoService;
 

seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/udf/DesEncrypt.java

@@ -19,7 +19,6 @@
 
 import org.apache.seatunnel.api.table.type.BasicType;
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;
-import org.apache.seatunnel.api.transform.sql.ZetaUDF;
 
 import com.google.auto.service.AutoService;
 

seatunnel-api/src/main/java/org/apache/seatunnel/api/transform/sql/ZetaUDF.java renamed to seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/udf/ZetaUDF.java

@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package org.apache.seatunnel.api.transform.sql;
+package org.apache.seatunnel.transform.sql.zeta.functions.udf;
 
 import org.apache.seatunnel.api.table.type.SeaTunnelDataType;