Fix reject regression (#14931)

This PR solves the regression introduced by #14622 (sorry about that).
It also adds a test to cover the regression.
Closes #14929.
This commit is contained in:
Renan Ribeiro
2025-01-27 20:23:44 -03:00
committed by GitHub
parent c0b4d19761
commit a2705f9eb5
2 changed files with 14 additions and 1 deletions

View File

@ -220,8 +220,14 @@ fn reject(
new_columns.append(&mut new_rows);
let has_integer_path_member = new_columns.iter().any(|path| {
path.members
.iter()
.any(|member| matches!(member, PathMember::Int { .. }))
});
match input {
PipelineData::ListStream(stream, ..) => {
PipelineData::ListStream(stream, ..) if !has_integer_path_member => {
let result = stream
.into_iter()
.map(move |mut value| {