Skip to content

Commit d7fe2f9

Browse files
committed
Follow up to #87303
1 parent 6cd016f commit d7fe2f9

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

src/Processors/QueryPlan/ReadFromMergeTree.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff 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

0 commit comments

Comments
 (0)