chore: add a setting to disable runtime filter (#17869)

* add a setting to disable runtime filter

* fix logic test

* rename

Author: SkyFan2002

src/query/settings/src/settings_default.rs

@@ -416,6 +416,13 @@ impl DefaultSettings {
                     range: Some(SettingRange::Numeric(0..=u64::MAX)),
                 }),
                 ("enable_bloom_runtime_filter", DefaultSettingValue {
+                    value: UserSettingValue::UInt64(1),
+                    desc: "Enables bloom runtime filter optimization for JOIN.",
+                    mode: SettingMode::Both,
+                    scope: SettingScope::Both,
+                    range: Some(SettingRange::Numeric(0..=1)),
+                }),
+                ("enable_join_runtime_filter", DefaultSettingValue {
                     value: UserSettingValue::UInt64(1),
                     desc: "Enables runtime filter optimization for JOIN.",
                     mode: SettingMode::Both,

src/query/settings/src/settings_getter_setter.rs

@@ -357,6 +357,10 @@ impl Settings {
         Ok(self.try_get_u64("enable_bloom_runtime_filter")? != 0)
     }
 
+    pub fn get_enable_join_runtime_filter(&self) -> Result<bool> {
+        Ok(self.try_get_u64("enable_join_runtime_filter")? != 0)
+    }
+
     pub fn get_prefer_broadcast_join(&self) -> Result<bool> {
         Ok(self.try_get_u64("prefer_broadcast_join")? != 0)
     }

src/query/sql/src/executor/physical_plans/physical_join_filter.rs

@@ -145,6 +145,11 @@ impl JoinRuntimeFilter {
         build_keys: &[RemoteExpr],
         probe_keys: Vec<Option<(RemoteExpr<String>, usize, usize)>>,
     ) -> Result<PhysicalRuntimeFilters> {
+        // Early return if runtime filter is disabled in settings
+        if !ctx.get_settings().get_enable_join_runtime_filter()? {
+            return Ok(Default::default());
+        }
+
         // Early return if runtime filters are not supported for this join type
         if !Self::supported_join_type_for_runtime_filter(&join.join_type) {
             return Ok(Default::default());

tests/sqllogictests/suites/mode/standalone/explain/join_reorder/chain.test

@@ -84,6 +84,64 @@ HashJoin
     ├── apply join filters: [#1]
     └── estimated rows: 100.00
 
+statement ok
+set enable_join_runtime_filter=0
+
+query T
+explain select * from t, t1, t2 where t.a = t1.a and t1.a = t2.a
+----
+HashJoin
+├── output columns: [t2.a (#2), t1.a (#1), t.a (#0)]
+├── join type: INNER
+├── build keys: [t.a (#0)]
+├── probe keys: [t2.a (#2)]
+├── keys is null equal: [false]
+├── filters: []
+├── build join filters:
+├── estimated rows: 1.00
+├── HashJoin(Build)
+│   ├── output columns: [t1.a (#1), t.a (#0)]
+│   ├── join type: INNER
+│   ├── build keys: [t.a (#0)]
+│   ├── probe keys: [t1.a (#1)]
+│   ├── keys is null equal: [false]
+│   ├── filters: []
+│   ├── build join filters:
+│   ├── estimated rows: 1.00
+│   ├── TableScan(Build)
+│   │   ├── table: default.join_reorder.t
+│   │   ├── output columns: [a (#0)]
+│   │   ├── read rows: 1
+│   │   ├── read size: < 1 KiB
+│   │   ├── partitions total: 1
+│   │   ├── partitions scanned: 1
+│   │   ├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 1 to 1>]
+│   │   ├── push downs: [filters: [], limit: NONE]
+│   │   └── estimated rows: 1.00
+│   └── TableScan(Probe)
+│       ├── table: default.join_reorder.t1
+│       ├── output columns: [a (#1)]
+│       ├── read rows: 10
+│       ├── read size: < 1 KiB
+│       ├── partitions total: 1
+│       ├── partitions scanned: 1
+│       ├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 1 to 1>]
+│       ├── push downs: [filters: [], limit: NONE]
+│       └── estimated rows: 10.00
+└── TableScan(Probe)
+    ├── table: default.join_reorder.t2
+    ├── output columns: [a (#2)]
+    ├── read rows: 100
+    ├── read size: < 1 KiB
+    ├── partitions total: 1
+    ├── partitions scanned: 1
+    ├── pruning stats: [segments: <range pruning: 1 to 1>, blocks: <range pruning: 1 to 1>]
+    ├── push downs: [filters: [], limit: NONE]
+    └── estimated rows: 100.00
+
+statement ok
+set enable_join_runtime_filter=1
+
 query T
 explain select * from t, t2, t1 where t.a = t1.a and t1.a = t2.a
 ----