diff --git a/be/src/runtime/runtime_state.h b/be/src/runtime/runtime_state.h index e1779895bba65a..e1891c23a4e014 100644 --- a/be/src/runtime/runtime_state.h +++ b/be/src/runtime/runtime_state.h @@ -472,11 +472,6 @@ class RuntimeState { return _query_options.__isset.enable_profile && _query_options.enable_profile; } - bool enable_scan_node_run_serial() const { - return _query_options.__isset.enable_scan_node_run_serial && - _query_options.enable_scan_node_run_serial; - } - bool enable_share_hash_table_for_broadcast_join() const { return _query_options.__isset.enable_share_hash_table_for_broadcast_join && _query_options.enable_share_hash_table_for_broadcast_join; diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java index ae68f64d75fbc4..6c94be89c91faa 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/Coordinator.java @@ -422,7 +422,6 @@ private void initQueryOptions(ConnectContext context) { if (this.queryOptions.getExecutionTimeout() < 1) { LOG.info("try set timeout less than 1", new RuntimeException("")); } - this.queryOptions.setEnableScanNodeRunSerial(context.getSessionVariable().isEnableScanRunSerial()); this.queryOptions.setFeProcessUuid(ExecuteEnv.getInstance().getProcessUUID()); this.queryOptions.setWaitFullBlockScheduleTimes(context.getSessionVariable().getWaitFullBlockScheduleTimes()); this.queryOptions.setMysqlRowBinaryFormat( diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index ab565defe656c8..0e121a24d74647 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -485,8 +485,6 @@ public class SessionVariable implements Serializable, Writable { public static final String ENABLE_CTE_MATERIALIZE = "enable_cte_materialize"; - public static final String ENABLE_SCAN_RUN_SERIAL = "enable_scan_node_run_serial"; - public static final String ENABLE_ANALYZE_COMPLEX_TYPE_COLUMN = "enable_analyze_complex_type_column"; public static final String EXTERNAL_TABLE_ANALYZE_PART_NUM = "external_table_analyze_part_num"; @@ -1021,12 +1019,6 @@ public enum IgnoreSplitType { @VariableMgr.VarAttr(name = ENABLE_ODBC_TRANSCATION) public boolean enableOdbcTransaction = false; - @VariableMgr.VarAttr(name = ENABLE_SCAN_RUN_SERIAL, description = { - "是否开启ScanNode串行读,以避免limit较小的情况下的读放大,可以提高查询的并发能力", - "Whether to enable ScanNode serial reading to avoid read amplification in cases of small limits" - + "which can improve query concurrency. default is false."}) - public boolean enableScanRunSerial = false; - @VariableMgr.VarAttr(name = ENABLE_SQL_CACHE, fuzzy = true) public boolean enableSqlCache = false; @@ -3169,10 +3161,6 @@ public void setShowHiddenColumns(boolean showHiddenColumns) { this.showHiddenColumns = showHiddenColumns; } - public boolean isEnableScanRunSerial() { - return enableScanRunSerial; - } - public boolean skipStorageEngineMerge() { return skipStorageEngineMerge; } diff --git a/gensrc/thrift/PaloInternalService.thrift b/gensrc/thrift/PaloInternalService.thrift index e29ad1c1a04d6f..6184c967ec0262 100644 --- a/gensrc/thrift/PaloInternalService.thrift +++ b/gensrc/thrift/PaloInternalService.thrift @@ -226,8 +226,8 @@ struct TQueryOptions { 72: optional bool enable_orc_lazy_mat = true 73: optional i64 scan_queue_mem_limit - - 74: optional bool enable_scan_node_run_serial = false; + // deprecated + 74: optional bool enable_scan_node_run_serial = false; 75: optional bool enable_insert_strict = false;