File tree Expand file tree Collapse file tree 1 file changed +1
-1
lines changed
Expand file tree Collapse file tree 1 file changed +1
-1
lines changed Original file line number Diff line number Diff line change @@ -1030,13 +1030,13 @@ Pipe ReadFromMergeTree::spreadMarkRangesAmongStreams(
10301030 = settings[Setting::merge_tree_read_split_ranges_into_intersecting_and_non_intersecting_injection_probability];
10311031 std::bernoulli_distribution fault (read_split_ranges_into_intersecting_and_non_intersecting_injection_probability);
10321032
1033- // / TODO: Should we consider row-policy filter here?
10341033 if (read_type != ReadType::ParallelReplicas &&
10351034 num_streams > 1 &&
10361035 read_split_ranges_into_intersecting_and_non_intersecting_injection_probability > 0.0 &&
10371036 fault (thread_local_rng) &&
10381037 !isQueryWithFinal () &&
10391038 data.merging_params .is_deleted_column .empty () &&
1039+ !query_info.row_level_filter &&
10401040 !query_info.prewhere_info &&
10411041 !lazily_read_info &&
10421042 !reader_settings.use_query_condition_cache && // / the query condition cache produces incorrect results with intersecting ranges
You can’t perform that action at this time.
0 commit comments