From 2d0a335bf390c351e43768a9ad72d5eafee01a9a Mon Sep 17 00:00:00 2001
From: congyi <15605187270@163.com>
Date: Thu, 7 Mar 2024 16:04:43 +0800
Subject: [PATCH] fix merger

---
 risingwave-test/hummock_001/checkpoint/0 | Bin 115 -> 115 bytes
 src/stream/src/executor/merge.rs         |   4 ++--
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/risingwave-test/hummock_001/checkpoint/0 b/risingwave-test/hummock_001/checkpoint/0
index cd919182374737f429d94c8e70fc5608155be10e..2b5e73bad767f85988f7f756353d2c397f608694 100644
GIT binary patch
delta 39
vcmXRe=Hx2mxML}#!@)F>Q<ITtBCDQ|L_@=u#^=i(b15`5Jow+U;4v2f<{l1<

delta 39
vcmXRe=Hx2mIA<=T!@)d}Q<IT-BCDQ|L_@=zo~6qkb15`5Jow+U;4v2f+*=Lq

diff --git a/src/stream/src/executor/merge.rs b/src/stream/src/executor/merge.rs
index b7899bcb68907..414bc8b4a65e8 100644
--- a/src/stream/src/executor/merge.rs
+++ b/src/stream/src/executor/merge.rs
@@ -471,7 +471,7 @@ mod tests {
             let handle = tokio::spawn(async move {
                 for epoch in epochs {
                     if epoch % 20 == 0 {
-                        tx.send(Message::Chunk(build_test_chunk(test_epoch(epoch))))
+                        tx.send(Message::Chunk(build_test_chunk(epoch)))
                             .await
                             .unwrap();
                     } else {
@@ -506,7 +506,7 @@ mod tests {
             if epoch % 20 == 0 {
                 for _ in 0..CHANNEL_NUMBER {
                     assert_matches!(merger.next().await.unwrap().unwrap(), Message::Chunk(chunk) => {
-                        assert_eq!(chunk.ops().len() as u64, test_epoch(epoch));
+                        assert_eq!(chunk.ops().len() as u64, epoch);
                     });
                 }
             } else if epoch as usize / 20 >= CHANNEL_NUMBER - 1 {