chore: a clearer error message for file source when the list fails (#…

…16294)
risingwavelabs · Apr 16, 2024 · cc95f48 · cc95f48
1 parent 1346a22
commit cc95f48
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/stream/src/executor/source/list_executor.rs b/src/stream/src/executor/source/list_executor.rs
@@ -90,7 +90,7 @@ impl<S: StateStore> FsListExecutor<S> {
             let rows = chunk
                 .into_iter()
                 .map(|item| {
-                    let page_item = item.unwrap();
+                    let page_item = item.expect("list file failed, please check whether the source connector is configured correctly.");
                     (
                         Op::Insert,
                         OwnedRow::new(vec![