diff --git a/risingwave-test/hummock_001/checkpoint/0 b/risingwave-test/hummock_001/checkpoint/0 index cd91918237473..2b5e73bad767f 100644 Binary files a/risingwave-test/hummock_001/checkpoint/0 and b/risingwave-test/hummock_001/checkpoint/0 differ 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 {