diff --git a/be/src/pipeline/pipeline_fragment_context.cpp b/be/src/pipeline/pipeline_fragment_context.cpp index b4c5646402ebd5..40f13346a97109 100644 --- a/be/src/pipeline/pipeline_fragment_context.cpp +++ b/be/src/pipeline/pipeline_fragment_context.cpp @@ -38,6 +38,7 @@ #include "common/config.h" #include "common/logging.h" #include "common/status.h" +#include "cloud/config.h" #include "exec/data_sink.h" #include "exec/exec_node.h" #include "exec/scan_node.h" @@ -821,6 +822,10 @@ Status PipelineFragmentContext::_create_sink(int sender_id, const TDataSink& thr DCHECK(thrift_sink.__isset.olap_table_sink); if (state->query_options().enable_memtable_on_sink_node && !_has_inverted_index_or_partial_update(thrift_sink.olap_table_sink)) { + if (config::is_cloud_mode()) { + return Status::InternalError( + "Move memtable is not supported in cloud mode, please disable it."); + } sink_ = std::make_shared(next_operator_builder_id(), _sink.get()); } else { diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp index 733cdfe2b50a6d..f936fb11def0a9 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp +++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp @@ -34,6 +34,7 @@ #include "common/config.h" #include "common/logging.h" +#include "cloud/config.h" #include "exec/data_sink.h" #include "exec/exec_node.h" #include "exec/scan_node.h" @@ -347,6 +348,10 @@ Status PipelineXFragmentContext::_create_data_sink(ObjectPool* pool, const TData case TDataSinkType::OLAP_TABLE_SINK: { if (state->query_options().enable_memtable_on_sink_node && !_has_inverted_index_or_partial_update(thrift_sink.olap_table_sink)) { + if (config::is_cloud_mode()) { + return Status::InternalError( + "Move memtable is not supported in cloud mode, please disable it."); + } _sink.reset(new OlapTableSinkV2OperatorX(pool, next_sink_operator_id(), row_desc, output_exprs)); } else { diff --git a/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy b/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy index 97a2f1515aa88d..bdb04a39156f18 100644 --- a/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy +++ b/regression-test/pipeline/cloud_p0/conf/regression-conf-custom.groovy @@ -18,4 +18,4 @@ testGroups = "p0" //exclude groups and exclude suites is more prior than include groups and include suites. excludeSuites = "test_index_failure_injection,test_dump_image,test_profile,test_spark_load,test_refresh_mtmv,test_bitmap_filter,test_information_schema_external,test_primary_key_partial_update_parallel" -excludeDirectories = "workload_manager_p1,nereids_rules_p0/subquery,unique_with_mow_p0/cluster_key,unique_with_mow_p0/ssb_unique_sql_zstd_cluster,point_query_p0,nereids_rules_p0/mv" +excludeDirectories = "workload_manager_p1,nereids_rules_p0/subquery,unique_with_mow_p0/cluster_key,unique_with_mow_p0/ssb_unique_sql_zstd_cluster,nereids_rules_p0/mv" diff --git a/regression-test/pipeline/cloud_p0/conf/session_variables.sql b/regression-test/pipeline/cloud_p0/conf/session_variables.sql index 962464502ec409..6dd78f8b3fea66 100644 --- a/regression-test/pipeline/cloud_p0/conf/session_variables.sql +++ b/regression-test/pipeline/cloud_p0/conf/session_variables.sql @@ -3,4 +3,5 @@ set global insert_visible_timeout_ms=60000; set global enable_auto_analyze=false; set global enable_audit_plugin=true; set global enable_memtable_on_sink_node=false; -set global enable_pipeline_x_engine=false; +set global enable_pipeline_x_engine = false; +set global enable_pipeline_engine = false;