We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 767054c commit 9e146aaCopy full SHA for 9e146aa
datafusion/physical-plan/src/sorts/sort.rs
@@ -1100,7 +1100,13 @@ impl ExecutionPlan for SortExec {
1100
context.runtime_env(),
1101
&self.metrics_set,
1102
)?;
1103
- let input_exec = if input_exec.supports_dynamic_filter_pushdown() {
+ let input_exec = if context
1104
+ .session_config()
1105
+ .options()
1106
+ .optimizer
1107
+ .enable_dynamic_filter_pushdown
1108
+ && input_exec.supports_dynamic_filter_pushdown()
1109
+ {
1110
input_exec
1111
.push_down_dynamic_filter(topk.dynamic_filter_source())?
1112
.unwrap_or(input_exec)
0 commit comments