Skip to content

Commit

Permalink
fix ut
Browse files Browse the repository at this point in the history
Signed-off-by: Richard Chien <[email protected]>
  • Loading branch information
stdrc committed Oct 23, 2024
1 parent 9a8adf4 commit 41bdd90
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions src/stream/src/executor/over_window/frame_finder.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1204,13 +1204,13 @@ mod tests {
let order_type = OrderType::ascending();

let range_frames = [
&create_range_frame(
create_range_frame(
order_data_type.clone(),
order_type,
Preceding(3i64),
Preceding(2i64),
),
&create_range_frame(
create_range_frame(
order_data_type.clone(),
order_type,
Preceding(1i64),
Expand Down Expand Up @@ -1252,7 +1252,7 @@ mod tests {
let order_data_type = DataType::Timestamp;
let order_type = OrderType::descending_nulls_first();

let range_frames = [&create_range_frame(
let range_frames = [create_range_frame(
order_data_type.clone(),
order_type,
Preceding(Interval::from_month_day_usec(1, 2, 3 * 1000 * 1000)),
Expand Down Expand Up @@ -1320,7 +1320,7 @@ mod tests {
expected_left: Sentinelled<ScalarImpl>,
expected_right: Sentinelled<ScalarImpl>,
) {
let frames = if matches!(order_data_type, DataType::Int32) {
let range_frames = if matches!(order_data_type, DataType::Int32) {
[create_range_frame(
order_data_type.clone(),
order_type,
Expand All @@ -1330,7 +1330,6 @@ mod tests {
} else {
panic!()
};
let range_frames = frames.iter().collect::<Vec<_>>();
let logical_order_value = Some(logical_order_value);
let cache_key_pk_len = 1;

Expand Down

0 comments on commit 41bdd90

Please sign in to comment.