diff --git a/regression-test/suites/fault_injection_p0/test_too_many_segments_fault_injection.groovy b/regression-test/suites/fault_injection_p0/test_too_many_segments_fault_injection.groovy index 1712928904cfec..1d830ae8705666 100644 --- a/regression-test/suites/fault_injection_p0/test_too_many_segments_fault_injection.groovy +++ b/regression-test/suites/fault_injection_p0/test_too_many_segments_fault_injection.groovy @@ -38,6 +38,11 @@ def create_table_sql = """ def columns = "col_0, col_1, col_2, col_3, col_4, col_5, col_6, col_7, col_8, col_9, col_10, col_11, col_12, col_13, col_14, col_15, col_16, col_17, col_18, col_19, col_20, col_21, col_22, col_23, col_24, col_25, col_26, col_27, col_28, col_29, col_30, col_31, col_32, col_33, col_34, col_35, col_36, col_37, col_38, col_39, col_40, col_41, col_42, col_43, col_44, col_45, col_46, col_47, col_48, col_49" suite("test_too_many_segments", "nonConcurrent,p2") { // the epic -238 case + if (isCloudMode()) { + logger.info("skip test_too_many_segments case, because cloud mode not support") + return + } + def runLoadWithTooManySegments = { String ak = getS3AK() String sk = getS3SK() diff --git a/regression-test/suites/load_p0/routine_load/test_disable_load.groovy b/regression-test/suites/load_p0/routine_load/test_disable_load.groovy index 38651775ab08cf..c1e118fcdc3ae9 100644 --- a/regression-test/suites/load_p0/routine_load/test_disable_load.groovy +++ b/regression-test/suites/load_p0/routine_load/test_disable_load.groovy @@ -21,6 +21,11 @@ import org.apache.kafka.clients.producer.ProducerRecord import org.apache.kafka.clients.producer.ProducerConfig suite("test_disable_load","nonConcurrent,p0") { + if (isCloudMode()) { + logger.info("skip test_disable_load case, because cloud mode not support") + return + } + String enabled = context.config.otherConfigs.get("enableKafkaTest") if (enabled != null && enabled.equalsIgnoreCase("true")) { // 1. send data diff --git a/regression-test/suites/load_p0/routine_load/test_routine_load_error_info.groovy b/regression-test/suites/load_p0/routine_load/test_routine_load_error_info.groovy index 7394d72c41d245..da51207266831f 100644 --- a/regression-test/suites/load_p0/routine_load/test_routine_load_error_info.groovy +++ b/regression-test/suites/load_p0/routine_load/test_routine_load_error_info.groovy @@ -21,6 +21,11 @@ import org.apache.kafka.clients.producer.ProducerRecord import org.apache.kafka.clients.producer.ProducerConfig suite("test_routine_load_error_info","nonConcurrent") { + if (isCloudMode()) { + logger.info("skip test_routine_load_error_info case, because cloud mode not support") + return + } + def kafkaCsvTpoics = [ "test_error_info", ]