minor

risingwavelabs · Dec 4, 2024 · 78e8de5 · 78e8de5
1 parent 6470ce7
commit 78e8de5
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/stream/src/executor/source/source_executor.rs b/src/stream/src/executor/source/source_executor.rs
@@ -1232,7 +1232,6 @@ mod tests {
         source_state_handler
             .init_epoch(EpochPair::new_test_epoch(test_epoch(2)))
             .await
-            .unwrap();
         source_state_handler
             .get(new_assignment[1].id())
             .await
@@ -1274,7 +1273,6 @@ mod tests {
         source_state_handler
             .init_epoch(EpochPair::new_test_epoch(5 * test_epoch(1)))
             .await
-            .unwrap();
 
         assert!(source_state_handler
             .try_recover_from_state_store(&prev_assignment[0])