diff --git a/src/stream/src/executor/merge.rs b/src/stream/src/executor/merge.rs
index 6ffc372c9b6bd..b7899bcb68907 100644
--- a/src/stream/src/executor/merge.rs
+++ b/src/stream/src/executor/merge.rs
@@ -464,7 +464,7 @@ mod tests {
         let merger = MergeExecutor::for_test(rxs);
         let mut handles = Vec::with_capacity(CHANNEL_NUMBER);
 
-        let epochs = (10..100u64).step_by(10).collect_vec();
+        let epochs = (10..1000u64).step_by(10).collect_vec();
 
         for (tx_id, tx) in txs.into_iter().enumerate() {
             let epochs = epochs.clone();