[pipelineX](fix) Fix incorrect runtime filter (#29860)

This commit is contained in:
Gabriel
2024-01-11 19:53:09 +08:00
committed by yiguolei
parent 407a4a285d
commit a4f29193f6
3 changed files with 3 additions and 4 deletions

View File

@ -721,7 +721,7 @@ public abstract class ScanNode extends PlanNode {
}
public boolean ignoreStorageDataDistribution(ConnectContext context) {
return !isKeySearch() && context != null
return context != null
&& context.getSessionVariable().isIgnoreStorageDataDistribution()
&& context.getSessionVariable().getEnablePipelineXEngine()
&& !fragment.isHasNullAwareLeftAntiJoin()