fix merger

risingwavelabs · Mar 7, 2024 · e2eff55 · e2eff55
1 parent 4dde294
commit e2eff55
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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();