address comments

kernel/src/scan/data_skipping.rs

@@ -107,10 +107,7 @@ impl DataSkippingFilter {
                 STATS_EXPR.clone(),
                 DataType::STRING,
             )
-            .map_err(|e| {
-                warn!("Failed to create stats selector evaluator: {}", e);
-                e
-            })
+            .inspect_err(|e| warn!("Failed to create stats selector evaluator: {}", e))
             .ok()?;
 
         let skipping_evaluator = engine
@@ -120,19 +117,13 @@ impl DataSkippingFilter {
                 Expr::struct_from([as_data_skipping_predicate(&predicate, false)?]),
                 PREDICATE_SCHEMA.clone(),
             )
-            .map_err(|e| {
-                warn!("Failed to create skipping evaluator: {}", e);
-                e
-            })
+            .inspect_err(|e| warn!("Failed to create skipping evaluator: {}", e))
             .ok()?;
 
         let filter_evaluator = engine
             .get_expression_handler()
             .get_evaluator(stats_schema.clone(), FILTER_EXPR.clone(), DataType::BOOLEAN)
-            .map_err(|e| {
-                warn!("Failed to create filter evaluator: {}", e);
-                e
-            })
+            .inspect_err(|e| warn!("Failed to create filter evaluator: {}", e))
             .ok()?;
 
         Some(Self {

kernel/src/scan/log_replay.rs

@@ -247,12 +247,16 @@ pub fn scan_action_iter(
         SCAN_ROW_DATATYPE.clone(),
     )?;
 
-    Ok(action_iter
+    let actions = action_iter
         .map(move |action_res| {
             let (batch, is_log_batch) = action_res?;
             log_scanner.process_scan_batch(add_transform.as_ref(), batch.as_ref(), is_log_batch)
         })
-        .filter(|res| res.as_ref().map_or(true, |(_, sv)| sv.contains(&true))))
+        .filter(|res: &Result<(Box<dyn EngineData>, Vec<bool>), Error>| {
+            res.as_ref().map_or(true, |(_, sv)| sv.contains(&true))
+        });
+
+    Ok(actions)
 }
 
 #[cfg(test)]