From e2eff55e8411f79e26d140aad687a0ba659d1656 Mon Sep 17 00:00:00 2001
From: congyi <15605187270@163.com>
Date: Thu, 7 Mar 2024 13:55:54 +0800
Subject: [PATCH] fix merger

---
 src/stream/src/executor/merge.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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();