This is an automated email from the ASF dual-hosted git repository.
hellostephen pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new b0d27728ee3 [case](udf) support run java udf case on cluster with
multiple BEs (#… (#36741)
b0d27728ee3 is described below
commit b0d27728ee34548d13a882eb03c4782ae8c243de
Author: Dongyang Li <[email protected]>
AuthorDate: Mon Jun 24 17:29:40 2024 +0800
[case](udf) support run java udf case on cluster with multiple BEs (#…
(#36741)
…36669)
Issue Number: close #xxx
<!--Describe your changes.-->
---------
## Proposed changes
Issue Number: close #xxx
<!--Describe your changes.-->
Co-authored-by: stephen <[email protected]>
---
.../org/apache/doris/regression/suite/Suite.groovy | 16 +++++++++++++++-
.../javaudf_p0/collect/test_javaudf_groupcount.groovy | 1 +
.../javaudf_p0/collect/test_javaudf_murmurhash3.groovy | 1 +
.../suites/javaudf_p0/date/test_javaudf_adddays.groovy | 1 +
.../javaudf_p0/date/test_javaudf_addisoperioud.groovy | 1 +
.../suites/javaudf_p0/date/test_javaudf_daydiff.groovy | 1 +
.../json/test_javaudf_convertfromcamelcase.groovy | 1 +
.../json/test_javaudf_converttocamelcase.groovy | 1 +
.../javaudf_p0/sanity/test_javaudf_assertequal.groovy | 1 +
.../javaudf_p0/sanity/test_javaudf_assertlessthan.groovy | 1 +
.../javaudf_p0/sanity/test_javaudf_assertudf.groovy | 1 +
.../suites/javaudf_p0/sketch/test_javaudf_md5.groovy | 1 +
.../javaudf_p0/test_javaudaf_my_date_datetime.groovy | 1 +
.../javaudf_p0/test_javaudaf_mygroupconcat_string.groovy | 1 +
.../suites/javaudf_p0/test_javaudaf_mysum_array.groovy | 1 +
.../suites/javaudf_p0/test_javaudaf_mysum_decimal.groovy | 1 +
.../javaudf_p0/test_javaudaf_mysum_float_double.groovy | 1 +
.../suites/javaudf_p0/test_javaudaf_mysum_int.groovy | 1 +
.../suites/javaudf_p0/test_javaudaf_null_test.groovy | 1 +
.../suites/javaudf_p0/test_javaudaf_return_map.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_agg_map.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_array.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_auth.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_boolean.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_case.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_date.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_decimal.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_float.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_int.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_map.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_multi_evaluate.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_no_input.groovy | 2 +-
.../suites/javaudf_p0/test_javaudf_null.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_ret_map.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_string.groovy | 1 +
.../suites/javaudf_p0/test_javaudf_with_decimal.groovy | 3 ++-
.../javaudf/collect/test_javaudf_groupcount.groovy | 1 +
.../javaudf/collect/test_javaudf_murmurhash3.groovy | 1 +
.../javaudf/collect/test_javaudf_sessionize.groovy | 1 +
.../nereids_p0/javaudf/date/test_javaudf_adddays.groovy | 1 +
.../javaudf/date/test_javaudf_addisoperioud.groovy | 1 +
.../nereids_p0/javaudf/date/test_javaudf_daydiff.groovy | 1 +
.../json/test_javaudf_convertfromcamelcase.groovy | 1 +
.../javaudf/json/test_javaudf_converttocamelcase.groovy | 1 +
.../javaudf/sanity/test_javaudf_assertequal.groovy | 1 +
.../javaudf/sanity/test_javaudf_assertlessthan.groovy | 1 +
.../javaudf/sanity/test_javaudf_assertudf.groovy | 1 +
.../nereids_p0/javaudf/sketch/test_javaudf_md5.groovy | 1 +
.../javaudf/test_javaudaf_my_date_datetime.groovy | 1 +
.../javaudf/test_javaudaf_mygroupconcat_string.groovy | 1 +
.../javaudf/test_javaudaf_mysum_decimal.groovy | 1 +
.../javaudf/test_javaudaf_mysum_float_double.groovy | 1 +
.../nereids_p0/javaudf/test_javaudaf_mysum_int.groovy | 1 +
.../nereids_p0/javaudf/test_javaudaf_null_test.groovy | 1 +
.../nereids_p0/javaudf/test_javaudf_boolean.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_case.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_date.groovy | 1 +
.../nereids_p0/javaudf/test_javaudf_decimal.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_float.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_int.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_null.groovy | 1 +
.../suites/nereids_p0/javaudf/test_javaudf_string.groovy | 1 +
62 files changed, 77 insertions(+), 3 deletions(-)
diff --git
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
index 82358185ab1..f771edade1b 100644
---
a/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
+++
b/regression-test/framework/src/main/groovy/org/apache/doris/regression/suite/Suite.groovy
@@ -864,5 +864,19 @@ class Suite implements GroovyInterceptable {
updateConfig oldConfig
}
}
-}
+ def scp_udf_file_to_all_be = { udf_file_path ->
+ if (!new File(udf_file_path).isAbsolute()) {
+ udf_file_path = new File(udf_file_path).getAbsolutePath()
+ }
+ def backendId_to_backendIP = [:]
+ def backendId_to_backendHttpPort = [:]
+ getBackendIpHttpPort(backendId_to_backendIP,
backendId_to_backendHttpPort)
+
+ def udf_file_dir = new File(udf_file_path).parent
+ backendId_to_backendIP.values().each { be_ip ->
+ sshExec ("root", be_ip, "ssh -o StrictHostKeyChecking=no
root@${be_ip} \"mkdir -p ${udf_file_dir}\"")
+ scpFiles("root", be_ip, udf_file_path, udf_file_path, false)
+ }
+ }
+}
diff --git
a/regression-test/suites/javaudf_p0/collect/test_javaudf_groupcount.groovy
b/regression-test/suites/javaudf_p0/collect/test_javaudf_groupcount.groovy
index 6e250655ecd..d8bdc231dd3 100644
--- a/regression-test/suites/javaudf_p0/collect/test_javaudf_groupcount.groovy
+++ b/regression-test/suites/javaudf_p0/collect/test_javaudf_groupcount.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_groupcount") {
def tableName = "test_javaudf_groupcount"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/collect/test_javaudf_murmurhash3.groovy
b/regression-test/suites/javaudf_p0/collect/test_javaudf_murmurhash3.groovy
index 8d1a6a08ab0..f22f3398d89 100644
--- a/regression-test/suites/javaudf_p0/collect/test_javaudf_murmurhash3.groovy
+++ b/regression-test/suites/javaudf_p0/collect/test_javaudf_murmurhash3.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_murmurhash3") {
def tableName = "test_javaudf_murmurhash3"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/date/test_javaudf_adddays.groovy
b/regression-test/suites/javaudf_p0/date/test_javaudf_adddays.groovy
index fc3ee135372..36e0321f1b8 100644
--- a/regression-test/suites/javaudf_p0/date/test_javaudf_adddays.groovy
+++ b/regression-test/suites/javaudf_p0/date/test_javaudf_adddays.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_adddays") {
def tableName = "test_javaudf_adddays"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/date/test_javaudf_addisoperioud.groovy
b/regression-test/suites/javaudf_p0/date/test_javaudf_addisoperioud.groovy
index 1b4a88ad6cc..15059e0a1e0 100644
--- a/regression-test/suites/javaudf_p0/date/test_javaudf_addisoperioud.groovy
+++ b/regression-test/suites/javaudf_p0/date/test_javaudf_addisoperioud.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_addisoperioud") {
def tableName = "test_javaudf_addisoperioud"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/date/test_javaudf_daydiff.groovy
b/regression-test/suites/javaudf_p0/date/test_javaudf_daydiff.groovy
index 4a78910ec0c..f31e34a5a56 100644
--- a/regression-test/suites/javaudf_p0/date/test_javaudf_daydiff.groovy
+++ b/regression-test/suites/javaudf_p0/date/test_javaudf_daydiff.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_daydiff") {
def tableName = "test_javaudf_daydiff"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/json/test_javaudf_convertfromcamelcase.groovy
b/regression-test/suites/javaudf_p0/json/test_javaudf_convertfromcamelcase.groovy
index b6076969f64..ae5e67d2312 100644
---
a/regression-test/suites/javaudf_p0/json/test_javaudf_convertfromcamelcase.groovy
+++
b/regression-test/suites/javaudf_p0/json/test_javaudf_convertfromcamelcase.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_convertfromcamelcase") {
def tableName = "test_javaudf_convertfromcamelcase"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/json/test_javaudf_converttocamelcase.groovy
b/regression-test/suites/javaudf_p0/json/test_javaudf_converttocamelcase.groovy
index 5fade3c30c4..218adb9fd58 100644
---
a/regression-test/suites/javaudf_p0/json/test_javaudf_converttocamelcase.groovy
+++
b/regression-test/suites/javaudf_p0/json/test_javaudf_converttocamelcase.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_converttocamelcase") {
def tableName = "test_javaudf_converttocamelcase"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertequal.groovy
b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertequal.groovy
index c0715abe236..0c2b6614bfe 100644
--- a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertequal.groovy
+++ b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertequal.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_assertequal") {
def tableName = "test_javaudf_assertequal"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertlessthan.groovy
b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertlessthan.groovy
index da043c31db9..8ea17390440 100644
---
a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertlessthan.groovy
+++
b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertlessthan.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_assertlessthan") {
def tableName = "test_javaudf_assertlessthan"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertudf.groovy
b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertudf.groovy
index 6649c8284e3..28c7791bb41 100644
--- a/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertudf.groovy
+++ b/regression-test/suites/javaudf_p0/sanity/test_javaudf_assertudf.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_assertudf") {
def tableName = "test_javaudf_assertudf"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/sketch/test_javaudf_md5.groovy
b/regression-test/suites/javaudf_p0/sketch/test_javaudf_md5.groovy
index 8f9b0cf2820..341a61d141b 100644
--- a/regression-test/suites/javaudf_p0/sketch/test_javaudf_md5.groovy
+++ b/regression-test/suites/javaudf_p0/sketch/test_javaudf_md5.groovy
@@ -25,6 +25,7 @@ suite("test_javaudf_md5") {
def tableName = "test_javaudf_md5"
File path = new File("${context.file.parent}")
def jarPath =
"""${path.getParent()}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/test_javaudaf_my_date_datetime.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_my_date_datetime.groovy
index 0d09c42e6d2..57f792a1bdd 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_my_date_datetime.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_my_date_datetime.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_my_date_datetime") {
def tableName = "test_javaudaf_my_date_datetime"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/test_javaudaf_mygroupconcat_string.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_mygroupconcat_string.groovy
index 46f13ae7873..71f01c9c88b 100644
---
a/regression-test/suites/javaudf_p0/test_javaudaf_mygroupconcat_string.groovy
+++
b/regression-test/suites/javaudf_p0/test_javaudaf_mygroupconcat_string.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_mygroupconcat_string") {
def tableName = "test_javaudaf_mygroupconcat_string"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_array.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_array.groovy
index 1f412648529..1ba52312b07 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_array.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_array.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_mysum_array") {
def tableName = "test_javaudaf_mysum_array"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_decimal.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_decimal.groovy
index 6526b6ceafa..e95259ed243 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_decimal.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_decimal.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_mysum_decimal") {
def tableName = "test_javaudaf_mysum_decimal"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_float_double.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_float_double.groovy
index 92ce70a91ba..6a5e8e1f255 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_float_double.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_float_double.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_mysum_float_double") {
def tableName = "test_javaudaf_mysum_float_double"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_int.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_int.groovy
index a07233c43e4..996f168cc11 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_mysum_int.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_mysum_int.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_mysum_int") {
def tableName = "test_javaudaf_mysum_int"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudaf_null_test.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_null_test.groovy
index 2e4548152c2..d3488b0c1d8 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_null_test.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_null_test.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudaf_null_test") {
def tableName = "test_javaudaf_null_test"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudaf_return_map.groovy
b/regression-test/suites/javaudf_p0/test_javaudaf_return_map.groovy
index 6485be198bd..dd28feadfa3 100644
--- a/regression-test/suites/javaudf_p0/test_javaudaf_return_map.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudaf_return_map.groovy
@@ -23,6 +23,7 @@ import java.nio.file.Paths
suite("test_javaudaf_return_map") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
try_sql("DROP FUNCTION IF EXISTS aggmap(int);")
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_agg_map.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_agg_map.groovy
index 03f84e5b34a..5e5445e20f2 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_agg_map.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_agg_map.groovy
@@ -23,6 +23,7 @@ import java.nio.file.Paths
suite("test_javaudf_agg_map") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
try_sql("DROP FUNCTION IF EXISTS mapii(Map<Int,Int>);")
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_array.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_array.groovy
index 89a89dc37dc..ee02ca17cc3 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_array.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_array.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_array") {
def tableName = "test_javaudf_array"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_auth.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_auth.groovy
index 5d08d8d0bd0..e1a6f6f8e86 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_auth.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_auth.groovy
@@ -23,6 +23,7 @@ import java.nio.file.Paths
suite("test_javaudf_auth") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
File path = new File(jarPath)
if (!path.exists()) {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_boolean.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_boolean.groovy
index a753c3c2226..98a642a9b96 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_boolean.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_boolean.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_boolean") {
def tableName = "test_javaudf_boolean"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_case.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_case.groovy
index 2ce55023b5b..7943013d79f 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_case.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_case.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_case") {
def tableName = "test_javaudf_datecasetest"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_date.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_date.groovy
index 60d52515fd1..91f7c771968 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_date.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_date.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_date") {
def tableName = "test_javaudf_date"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
try {
sql """ DROP TABLE IF EXISTS ${tableName} """
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_decimal.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_decimal.groovy
index 664dd0abc9f..2276a0c4622 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_decimal.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_decimal.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_decimal") {
def tableName = "test_javaudf_decimal"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_float.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_float.groovy
index 21c7e37399c..d27f209a6de 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_float.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_float.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_float") {
def tableName = "test_javaudf_float"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_int.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_int.groovy
index a7d2615e86b..a764fa11c8b 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_int.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_int.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_int") {
def tableName = "test_javaudf_int"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_map.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_map.groovy
index 4f7b89fd92f..4fe8d97c32b 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_map.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_map.groovy
@@ -23,6 +23,7 @@ import java.nio.file.Paths
suite("test_javaudf_map") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
try_sql("DROP FUNCTION IF EXISTS udfii(Map<INT, INT>);")
diff --git
a/regression-test/suites/javaudf_p0/test_javaudf_multi_evaluate.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_multi_evaluate.groovy
index d8f390bbaac..528880d320e 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_multi_evaluate.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_multi_evaluate.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_multi_evaluate") {
def tableName = "test_javaudf_multi_evaluate"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_no_input.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_no_input.groovy
index fd3e74e2137..1f905d6ea1c 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_no_input.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_no_input.groovy
@@ -24,7 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_no_input") {
def tableName = "test_javaudf_no_input"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
-
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_null.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_null.groovy
index 7e884c9b2ea..a710b1cb932 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_null.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_null.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_null") {
def tableName = "test_javaudf_null"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_ret_map.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_ret_map.groovy
index 8421a6699a2..86a3c7b4dd2 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_ret_map.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_ret_map.groovy
@@ -23,6 +23,7 @@ import java.nio.file.Paths
suite("test_javaudf_ret_map") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
try_sql("DROP FUNCTION IF EXISTS retii(map<int,int>);")
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_string.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_string.groovy
index 07a1ac06975..c6d7a7311f5 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_string.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_string.groovy
@@ -24,6 +24,7 @@ import java.nio.file.Paths
suite("test_javaudf_string") {
def tableName = "test_javaudf_string"
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/javaudf_p0/test_javaudf_with_decimal.groovy
b/regression-test/suites/javaudf_p0/test_javaudf_with_decimal.groovy
index bf288728319..e56ffc4a8c9 100644
--- a/regression-test/suites/javaudf_p0/test_javaudf_with_decimal.groovy
+++ b/regression-test/suites/javaudf_p0/test_javaudf_with_decimal.groovy
@@ -23,7 +23,8 @@ import java.nio.file.Paths
suite("test_javaudf_with_decimal") {
def jarPath =
"""${context.file.parent}/jars/java-udf-case-jar-with-dependencies.jar"""
- log.info("Jar path: ${jarPath}".toString())
+ scp_udf_file_to_all_be(jarPath)
+ log.info("Jar path: ${jarPath}")
try {
try_sql("drop function IF EXISTS getarrscale(Array<Decimal(15,3)>);")
try_sql("drop function IF EXISTS
getmapscale(Map<Decimal(15,3),Decimal(15,6)>);")
diff --git
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_groupcount.groovy
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_groupcount.groovy
index aa1da819935..bec60cd7ab0 100644
---
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_groupcount.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_groupcount.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_groupcount") {
def tableName = "test_javaudf_groupcount"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_murmurhash3.groovy
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_murmurhash3.groovy
index 20ca5802016..1db97994c8d 100644
---
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_murmurhash3.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_murmurhash3.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_murmurhash3") {
def tableName = "test_javaudf_murmurhash3"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_sessionize.groovy
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_sessionize.groovy
index 286303ce495..e01a63e19c9 100644
---
a/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_sessionize.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/collect/test_javaudf_sessionize.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_sessionize") {
def tableName = "test_javaudf_sessionize"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_adddays.groovy
b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_adddays.groovy
index db67556b380..15adae9ba42 100644
--- a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_adddays.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_adddays.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_adddays") {
def tableName = "test_javaudf_adddays"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_addisoperioud.groovy
b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_addisoperioud.groovy
index 44634fc75e4..d8b62b885ea 100644
---
a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_addisoperioud.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_addisoperioud.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_addisoperioud") {
def tableName = "test_javaudf_addisoperioud"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_daydiff.groovy
b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_daydiff.groovy
index cafceb01994..e322b47b569 100644
--- a/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_daydiff.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/date/test_javaudf_daydiff.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_daydiff") {
def tableName = "test_javaudf_daydiff"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_convertfromcamelcase.groovy
b/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_convertfromcamelcase.groovy
index 74721a6d594..dd85c496c5a 100644
---
a/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_convertfromcamelcase.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_convertfromcamelcase.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_convertfromcamelcase") {
def tableName = "test_javaudf_convertfromcamelcase"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_converttocamelcase.groovy
b/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_converttocamelcase.groovy
index fb211fe1a96..7d95205a15d 100644
---
a/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_converttocamelcase.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/json/test_javaudf_converttocamelcase.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_converttocamelcase") {
def tableName = "test_javaudf_converttocamelcase"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertequal.groovy
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertequal.groovy
index d0965aa83f2..5cde8e6a046 100644
---
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertequal.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertequal.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_assertequal") {
def tableName = "test_javaudf_assertequal"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertlessthan.groovy
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertlessthan.groovy
index 7af57c54029..548085eaf61 100644
---
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertlessthan.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertlessthan.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_assertlessthan") {
def tableName = "test_javaudf_assertlessthan"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertudf.groovy
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertudf.groovy
index 74554294930..599395b3e0f 100644
---
a/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertudf.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/sanity/test_javaudf_assertudf.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_assertudf") {
def tableName = "test_javaudf_assertudf"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/sketch/test_javaudf_md5.groovy
b/regression-test/suites/nereids_p0/javaudf/sketch/test_javaudf_md5.groovy
index 63296411c8d..39da0fc1fe7 100644
--- a/regression-test/suites/nereids_p0/javaudf/sketch/test_javaudf_md5.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/sketch/test_javaudf_md5.groovy
@@ -28,6 +28,7 @@ suite("nereids_test_javaudf_md5") {
def tableName = "test_javaudf_md5"
File path = new File("${context.file.parent}")
def jarPath =
"""${context.file.parent}/../../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_my_date_datetime.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_my_date_datetime.groovy
index d5fd07222f1..5f2b90f6ac4 100644
---
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_my_date_datetime.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_my_date_datetime.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_my_date_datetime") {
def tableName = "test_javaudaf_my_date_datetime"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mygroupconcat_string.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mygroupconcat_string.groovy
index 40f4c08f0ca..a863a20a1cb 100644
---
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mygroupconcat_string.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mygroupconcat_string.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_mygroupconcat_string") {
def tableName = "test_javaudaf_mygroupconcat_string"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_decimal.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_decimal.groovy
index 8ac4ed04f62..040b260b7c8 100644
---
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_decimal.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_decimal.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_mysum_decimal") {
def tableName = "test_javaudaf_mysum_decimal"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_float_double.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_float_double.groovy
index 947cbcde2ad..36deeb1feac 100644
---
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_float_double.groovy
+++
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_float_double.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_mysum_float_double") {
def tableName = "test_javaudaf_mysum_float_double"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_int.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_int.groovy
index 4f4d4fc1b22..c7db8a717ff 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_int.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_mysum_int.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_mysum_int") {
def tableName = "test_javaudaf_mysum_int"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_null_test.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_null_test.groovy
index ab7cf28e334..090d4c6ba86 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudaf_null_test.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudaf_null_test.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudaf_null_test") {
def tableName = "test_javaudaf_null_test"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudf_boolean.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_boolean.groovy
index 77a49974155..9b544b6dc07 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_boolean.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_boolean.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_boolean") {
def tableName = "test_javaudf_boolean"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/nereids_p0/javaudf/test_javaudf_case.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_case.groovy
index d395189562c..7b9ff6de292 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_case.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_case.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_case") {
def tableName = "test_javaudf_datecasetest"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/nereids_p0/javaudf/test_javaudf_date.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_date.groovy
index 747444d599d..c666ff9c33a 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_date.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_date.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_date") {
def tableName = "test_javaudf_date"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
try {
sql """ DROP TABLE IF EXISTS ${tableName} """
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudf_decimal.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_decimal.groovy
index 787fe00a628..4ea6bc0be78 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_decimal.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_decimal.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_decimal") {
def tableName = "test_javaudf_decimal"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudf_float.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_float.groovy
index 2ce1e9be8de..d6668d9e2e1 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_float.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_float.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_float") {
def tableName = "test_javaudf_float"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/nereids_p0/javaudf/test_javaudf_int.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_int.groovy
index 2d2212a95d6..613f686e261 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_int.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_int.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_int") {
def tableName = "test_javaudf_int"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git a/regression-test/suites/nereids_p0/javaudf/test_javaudf_null.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_null.groovy
index c0bd96fc783..5b9a94dcb5c 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_null.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_null.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_null") {
def tableName = "test_javaudf_null"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
diff --git
a/regression-test/suites/nereids_p0/javaudf/test_javaudf_string.groovy
b/regression-test/suites/nereids_p0/javaudf/test_javaudf_string.groovy
index 1eac4c78660..4d1ecd4c109 100644
--- a/regression-test/suites/nereids_p0/javaudf/test_javaudf_string.groovy
+++ b/regression-test/suites/nereids_p0/javaudf/test_javaudf_string.groovy
@@ -27,6 +27,7 @@ suite("nereids_test_javaudf_string") {
def tableName = "test_javaudf_string"
def jarPath =
"""${context.file.parent}/../../javaudf_p0/jars/java-udf-case-jar-with-dependencies.jar"""
+ scp_udf_file_to_all_be(jarPath)
log.info("Jar path: ${jarPath}".toString())
try {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
