chore: bump toolchain to nightly-2023-04-07

ci/build-ci-image.sh

@@ -14,7 +14,7 @@ export RUST_TOOLCHAIN=$(cat ../rust-toolchain)
 # !!! CHANGE THIS WHEN YOU WANT TO BUMP CI IMAGE !!! #
 #          AND ALSO docker-compose.yml               #
 ######################################################
-export BUILD_ENV_VERSION=v20230403
+export BUILD_ENV_VERSION=v20230407
 
 export BUILD_TAG="public.ecr.aws/x5u3w5h6/rw-build-env:${BUILD_ENV_VERSION}"
 

ci/docker-compose.yml

@@ -34,28 +34,28 @@ services:
       retries: 5
 
   source-test-env:
-    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230403
+    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230407
     depends_on:
       - mysql
       - db
     volumes:
       - ..:/risingwave
 
   sink-test-env:
-    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230403
+    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230407
     depends_on:
       - mysql
       - db
     volumes:
       - ..:/risingwave
 
   rw-build-env:
-    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230403
+    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230407
     volumes:
       - ..:/risingwave
 
   regress-test-env:
-    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230403
+    image: public.ecr.aws/x5u3w5h6/rw-build-env:v20230407
     depends_on:
       db:
         condition: service_healthy

docs/developer-guide.md

@@ -72,7 +72,7 @@ RiseDev is the development mode of RisingWave. To develop RisingWave, you need t
 * OpenSSL
 * PostgreSQL (psql) (>= 14.1)
 * Tmux (>= v3.2a)
-* LLVM 15 (For macOS only, to workaround some bugs in macOS toolchain. See https://github.com/risingwavelabs/risingwave/issues/6205).
+* LLVM 16 (For macOS only, to workaround some bugs in macOS toolchain. See https://github.com/risingwavelabs/risingwave/issues/6205).
 
 To install the dependencies on macOS, run:
 

rust-toolchain

@@ -1 +1 @@
-nightly-2023-03-01
+nightly-2023-04-07

src/batch/src/executor/mod.rs

@@ -237,9 +237,7 @@ mod tests {
 
     #[test]
     fn test_clone_for_plan() {
-        let plan_node = PlanNode {
-            ..Default::default()
-        };
+        let plan_node = PlanNode::default();
         let task_id = &TaskId {
             task_id: 1,
             stage_id: 1,
@@ -251,9 +249,7 @@ mod tests {
             ComputeNodeContext::for_test(),
             to_committed_batch_query_epoch(u64::MAX),
         );
-        let child_plan = &PlanNode {
-            ..Default::default()
-        };
+        let child_plan = &PlanNode::default();
         let cloned_builder = builder.clone_for_plan(child_plan);
         assert_eq!(builder.task_id, cloned_builder.task_id);
     }

src/cmd_all/src/lib.rs

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 
 pub mod playground;
 pub use playground::*;

src/common/src/lib.rs

@@ -23,7 +23,7 @@
 #![feature(lint_reasons)]
 #![feature(generators)]
 #![feature(map_try_insert)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]
 #![feature(let_chains)]

src/connector/src/lib.rs

@@ -21,7 +21,7 @@
 #![feature(trait_alias)]
 #![feature(binary_heap_drain_sorted)]
 #![feature(lint_reasons)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(result_option_inspect)]
 #![feature(let_chains)]
 #![feature(box_into_inner)]

src/expr/macro/src/gen.rs

@@ -115,6 +115,10 @@ impl FunctionAttr {
         let exprs = (0..num_args)
             .map(|i| format_ident!("e{i}"))
             .collect::<Vec<_>>();
+        #[expect(
+            clippy::redundant_clone,
+            reason = "false positive https://github.com/rust-lang/rust-clippy/issues/10545"
+        )]
         let exprs0 = exprs.clone();
 
         let build_expr = if self.ret == "varchar" && self.user_fn.is_writer_style() {

src/expr/macro/src/lib.rs

@@ -12,6 +12,8 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
+#![feature(lint_reasons)]
+
 use proc_macro::TokenStream;
 use proc_macro2::TokenStream as TokenStream2;
 use quote::ToTokens;

src/expr/src/lib.rs

@@ -19,7 +19,7 @@
 #![feature(lint_reasons)]
 #![feature(iterator_try_collect)]
 #![feature(exclusive_range_pattern)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(try_blocks)]
 
 mod error;

src/frontend/src/lib.rs

@@ -25,7 +25,7 @@
 #![feature(assert_matches)]
 #![feature(lint_reasons)]
 #![feature(box_patterns)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(result_option_inspect)]
 #![feature(macro_metavar_expr)]
 #![feature(slice_internals)]

src/frontend/src/optimizer/rule/index_selection_rule.rs

@@ -102,6 +102,10 @@ impl Rule for IndexSelectionRule {
             self.estimate_full_table_scan_cost(logical_scan, primary_table_row_size),
         );
 
+        #[expect(
+            clippy::redundant_clone,
+            reason = "false positive https://github.com/rust-lang/rust-clippy/issues/10545"
+        )]
         let mut final_plan: PlanRef = logical_scan.clone().into();
         let mut min_cost = primary_cost.clone();
 

src/frontend/src/scheduler/distributed/query.rs

@@ -368,9 +368,7 @@ impl QueryRunner {
         let root_stage_result = QueryResultFetcher::new(
             root_task_output_id,
             // Execute in local, so no need to fill meaningful address.
-            HostAddress {
-                ..Default::default()
-            },
+            HostAddress::default(),
             chunk_rx,
             self.query.query_id.clone(),
             self.query_execution_info.clone(),

src/java_binding/src/lib.rs

@@ -14,7 +14,7 @@
 
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(type_alias_impl_trait)]
 
 mod hummock_iterator;

src/meta/src/hummock/manager/tests.rs

@@ -847,9 +847,7 @@ async fn test_trigger_manual_compaction() {
     {
         let option = ManualCompactionOption {
             level: 6,
-            key_range: KeyRange {
-                ..Default::default()
-            },
+            key_range: KeyRange::default(),
             ..Default::default()
         };
 

src/meta/src/lib.rs

@@ -15,7 +15,6 @@
 #![allow(clippy::derive_partial_eq_without_eq)]
 #![feature(trait_alias)]
 #![feature(binary_heap_drain_sorted)]
-#![feature(option_result_contains)]
 #![feature(type_alias_impl_trait)]
 #![feature(drain_filter)]
 #![feature(custom_test_frameworks)]
@@ -25,7 +24,7 @@
 #![feature(is_some_and)]
 #![feature(btree_drain_filter)]
 #![feature(result_option_inspect)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(let_chains)]
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]

src/meta/src/rpc/service/hummock_service.rs

@@ -299,9 +299,7 @@ where
             }
 
             None => {
-                option.key_range = KeyRange {
-                    ..Default::default()
-                }
+                option.key_range = KeyRange::default();
             }
         }
 

src/meta/src/stream/stream_manager.rs

@@ -646,9 +646,7 @@ mod tests {
             &self,
             _request: Request<BarrierCompleteRequest>,
         ) -> std::result::Result<Response<BarrierCompleteResponse>, Status> {
-            Ok(Response::new(BarrierCompleteResponse {
-                ..Default::default()
-            }))
+            Ok(Response::new(BarrierCompleteResponse::default()))
         }
 
         async fn wait_epoch_commit(

src/object_store/src/lib.rs

@@ -14,7 +14,7 @@
 
 #![feature(trait_alias)]
 #![feature(type_alias_impl_trait)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(lint_reasons)]
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]

src/sqlparser/tests/sqlparser_common.rs

@@ -1715,9 +1715,7 @@ fn parse_explain_analyze_with_simple_select() {
     run_explain_analyze(
         "EXPLAIN SELECT sqrt(id) FROM foo",
         false,
-        ExplainOptions {
-            ..Default::default()
-        },
+        ExplainOptions::default(),
     );
     run_explain_analyze(
         "EXPLAIN (VERBOSE) SELECT sqrt(id) FROM foo",
@@ -1730,9 +1728,7 @@ fn parse_explain_analyze_with_simple_select() {
     run_explain_analyze(
         "EXPLAIN ANALYZE SELECT sqrt(id) FROM foo",
         true,
-        ExplainOptions {
-            ..Default::default()
-        },
+        ExplainOptions::default(),
     );
     run_explain_analyze(
         "EXPLAIN (TRACE) SELECT sqrt(id) FROM foo",

src/storage/backup/src/lib.rs

@@ -15,7 +15,6 @@
 #![allow(clippy::derive_partial_eq_without_eq)]
 #![feature(trait_alias)]
 #![feature(binary_heap_drain_sorted)]
-#![feature(option_result_contains)]
 #![feature(type_alias_impl_trait)]
 #![feature(drain_filter)]
 #![feature(custom_test_frameworks)]
@@ -25,7 +24,7 @@
 #![feature(is_some_and)]
 #![feature(btree_drain_filter)]
 #![feature(result_option_inspect)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(let_chains)]
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]

src/storage/benches/bench_block_iter.rs

@@ -12,7 +12,7 @@
 // See the License for the specific language governing permissions and
 // limitations under the License.
 
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 use std::sync::LazyLock;
 
 use bytes::{BufMut, Bytes, BytesMut};

src/storage/hummock_test/src/hummock_storage_tests.rs

@@ -428,7 +428,7 @@ async fn test_state_store_sync() {
 
     let read_version = hummock_storage.read_version();
 
-    let epoch1: _ = read_version.read().committed().max_committed_epoch() + 1;
+    let epoch1 = read_version.read().committed().max_committed_epoch() + 1;
     hummock_storage.init(epoch1);
 
     // ingest 16B batch

src/storage/src/lib.rs

@@ -35,7 +35,7 @@
 #![feature(is_sorted)]
 #![feature(btree_drain_filter)]
 #![feature(exact_size_is_empty)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![cfg_attr(coverage, feature(no_coverage))]
 #![recursion_limit = "256"]
 #![feature(error_generic_member_access)]

src/storage/src/memory.rs

@@ -636,9 +636,7 @@ impl<R: RangeKv> StateStore for RangeKvStateStore<R> {
         async move {
             self.inner.flush()?;
             // memory backend doesn't need to push to S3, so this is a no-op
-            Ok(SyncResult {
-                ..Default::default()
-            })
+            Ok(SyncResult::default())
         }
     }
 

src/stream/src/lib.rs

@@ -15,7 +15,6 @@
 #![allow(rustdoc::private_intra_doc_links)]
 #![allow(clippy::derive_partial_eq_without_eq)]
 #![allow(incomplete_features)] // for feature(return_position_impl_trait_in_trait)
-#![feature(binary_heap_retain)]
 #![feature(iterator_try_collect)]
 #![feature(trait_alias)]
 #![feature(type_alias_impl_trait)]
@@ -34,7 +33,7 @@
 #![feature(result_option_inspect)]
 #![feature(never_type)]
 #![feature(btreemap_alloc)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(error_generic_member_access)]
 #![feature(provide_any)]
 #![feature(btree_drain_filter)]

src/tests/simulation/src/lib.rs

@@ -15,7 +15,7 @@
 #![cfg(madsim)]
 #![feature(trait_alias)]
 #![feature(lint_reasons)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 
 pub mod client;
 pub mod cluster;

src/tests/simulation/src/main.rs

@@ -13,7 +13,7 @@
 // limitations under the License.
 
 #![cfg_attr(not(madsim), allow(dead_code))]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 
 use std::path::PathBuf;
 

src/tests/sqlsmith/src/lib.rs

@@ -14,7 +14,7 @@
 
 #![feature(let_chains)]
 #![feature(if_let_guard)]
-#![feature(once_cell)]
+#![feature(lazy_cell)]
 #![feature(box_patterns)]
 
 use rand::prelude::SliceRandom;

src/utils/pgwire/src/lib.rs

@@ -13,7 +13,7 @@
 // limitations under the License.
 
 #![feature(io_error_other)]
-#![feature(lint_reasons, once_cell)]
+#![feature(lint_reasons)]
 #![feature(trait_alias)]
 #![feature(result_option_inspect)]
 #![feature(iterator_try_collect)]

src/utils/task_stats_alloc/src/lib.rs

@@ -14,7 +14,6 @@
 
 #![feature(allocator_api)]
 #![feature(lint_reasons)]
-#![feature(atomic_mut_ptr)]
 
 use std::alloc::{GlobalAlloc, Layout, System};
 use std::future::Future;