From ddb3b46fff7ea696d27fe083685d9bf865e05c46 Mon Sep 17 00:00:00 2001 From: yagagagaga Date: Fri, 25 Jul 2025 09:50:10 +0800 Subject: [PATCH] branch-2.1: [fix](p2) throw Exception if hdfs is not enable (#52761) (#53811) (cherry picked from PR #52761) --- .../cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy | 2 +- .../create_table_use_dynamic_partition_by_hdfs.groovy | 2 +- .../create_table_use_partition_policy_by_hdfs.groovy | 2 +- .../create_table_use_policy_by_hdfs.groovy | 2 +- .../suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy | 2 +- .../modify_replica_use_partition_by_hdfs.groovy | 2 +- .../table_modify_resouce_and_policy_by_hdfs.groovy | 2 +- 7 files changed, 7 insertions(+), 7 deletions(-) diff --git a/regression-test/suites/cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy index 721c12d7dd..7354fc7489 100644 --- a/regression-test/suites/cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/add_drop_partition_by_hdfs.groovy @@ -20,7 +20,7 @@ import java.time.LocalDate; suite("add_drop_partition_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> def i = meta_url.indexOf("/api") diff --git a/regression-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition_by_hdfs.groovy index 0e64132ba5..bf811b217f 100644 --- a/regression-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/create_table_use_dynamic_partition_by_hdfs.groovy @@ -20,7 +20,7 @@ import java.time.LocalDate; suite("cold_heat_dynamic_partition_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> def i = meta_url.indexOf("/api") diff --git a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy index ce4264480a..8004b2dc77 100644 --- a/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/create_table_use_partition_policy_by_hdfs.groovy @@ -19,7 +19,7 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("create_table_use_partition_policy_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> def i = meta_url.indexOf("/api") diff --git a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy index 408f2e6275..43e9e26cc9 100644 --- a/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/create_table_use_policy_by_hdfs.groovy @@ -19,7 +19,7 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("create_table_use_policy_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> def i = meta_url.indexOf("/api") diff --git a/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy index 8aa2ded305..089c89b72d 100644 --- a/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/load_colddata_to_hdfs.groovy @@ -19,7 +19,7 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("load_colddata_to_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> diff --git a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy index a55ead4870..54fdc93df9 100644 --- a/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/modify_replica_use_partition_by_hdfs.groovy @@ -19,7 +19,7 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("modify_replica_use_partition_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def replicaNum = getFeConfig("force_olap_table_replication_num") setFeConfig("force_olap_table_replication_num", 0) diff --git a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy index 601d42ab0d..574d9ef44f 100644 --- a/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy +++ b/regression-test/suites/cold_heat_separation_p2/table_modify_resouce_and_policy_by_hdfs.groovy @@ -19,7 +19,7 @@ import org.codehaus.groovy.runtime.IOGroovyMethods suite("table_modify_resouce_by_hdfs") { if (!enableHdfs()) { - logger.info("skip this case because hdfs is not enabled"); + throw new RuntimeException("Hdfs is not enabled, if you want to skip this case, please mute it in regression-conf.groovy"); } def fetchBeHttp = { check_func, meta_url -> def i = meta_url.indexOf("/api")