Skip to content

Commit 9d3e587

Browse files
committed
bump toolchain
Signed-off-by: TennyZhuang <zty0826@gmail.com>
1 parent 94feca2 commit 9d3e587

File tree

37 files changed

+75
-69
lines changed

37 files changed

+75
-69
lines changed

Cargo.lock

Lines changed: 2 additions & 2 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

Cargo.toml

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
[workspace]
2+
resolver = "2"
23
members = [
34
"scripts/source/prepare_ci_pubsub",
45
"src/batch",

ci/rust-toolchain

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
[toolchain]
2-
channel = "nightly-2023-05-31"
2+
channel = "nightly-2023-07-28"

src/common/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
// limitations under the License.
1414

1515
#![allow(rustdoc::private_intra_doc_links)]
16-
#![feature(drain_filter)]
16+
#![feature(extract_if)]
1717
#![feature(trait_alias)]
1818
#![feature(binary_heap_drain_sorted)]
1919
#![feature(is_sorted)]

src/common/src/vnode_mapping/vnode_placement.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ pub fn place_vnode(
4949
// evenly among workers.
5050
let mut selected_pu_ids = Vec::new();
5151
while !new_pus.is_empty() {
52-
new_pus.drain_filter(|ps| {
52+
let _ = new_pus.extract_if(|ps| {
5353
if let Some(p) = ps.next() {
5454
selected_pu_ids.push(p.id);
5555
false

src/ctl/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@
1313
// limitations under the License.
1414

1515
#![feature(let_chains)]
16-
#![feature(hash_drain_filter)]
16+
#![feature(hash_extract_if)]
1717

1818
use anyhow::Result;
1919
use clap::{Parser, Subcommand};

src/frontend/src/expr/utils.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -307,7 +307,7 @@ pub fn factorization_expr(expr: ExprImpl) -> Vec<ExprImpl> {
307307
let (last, remaining) = disjunctions.split_last_mut().unwrap();
308308
// now greatest_common_factor == [C, D]
309309
let greatest_common_divider: Vec<_> = last
310-
.drain_filter(|factor| remaining.iter().all(|expr| expr.contains(factor)))
310+
.extract_if(|factor| remaining.iter().all(|expr| expr.contains(factor)))
311311
.collect();
312312
for disjunction in remaining {
313313
// remove common factors

src/frontend/src/handler/alter_table_column.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -131,7 +131,7 @@ pub async fn handle_alter_table_column(
131131
// Locate the column by name and remove it.
132132
let column_name = column_name.real_value();
133133
let removed_column = columns
134-
.drain_filter(|c| c.name.real_value() == column_name)
134+
.extract_if(|c| c.name.real_value() == column_name)
135135
.at_most_one()
136136
.ok()
137137
.unwrap();

src/frontend/src/lib.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,7 +19,7 @@
1919
#![feature(generators)]
2020
#![feature(proc_macro_hygiene, stmt_expr_attributes)]
2121
#![feature(trait_alias)]
22-
#![feature(drain_filter)]
22+
#![feature(extract_if)]
2323
#![feature(if_let_guard)]
2424
#![feature(let_chains)]
2525
#![feature(assert_matches)]

src/frontend/src/optimizer/plan_node/generic/join.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -407,7 +407,7 @@ pub fn push_down_into_join(
407407
// Do not push now on to the on, it will be pulled up into a filter instead.
408408
let on = Condition {
409409
conjunctions: conjunctions
410-
.drain_filter(|expr| expr.count_nows() == 0)
410+
.extract_if(|expr| expr.count_nows() == 0)
411411
.collect(),
412412
};
413413
predicate.conjunctions = conjunctions;

0 commit comments

Comments
 (0)