fix format string

risingwavelabs · Dec 13, 2024 · aab72b4 · aab72b4
1 parent 7f6534e
commit aab72b4
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/src/stream/benches/stream_hash_join_mem.rs b/src/stream/benches/stream_hash_join_mem.rs
@@ -45,12 +45,14 @@ async fn main() {
     } else {
         100_000
     };
-    let (tx_l, tx_r, out) = setup_bench_stream_hash_join(amp, HashJoinWorkload::NotInCache, JoinType::Inner).await;
+    let workload = HashJoinWorkload::NotInCache;
+    let join_type = JoinType::Inner;
+    let (tx_l, tx_r, out) = setup_bench_stream_hash_join(amp, workload, join_type).await;
     {
         // Start the profiler later, after we have ingested the data for hash join build-side.
         #[cfg(feature = "dhat-heap")]
         let _profiler = dhat::Profiler::new_heap();
 
-        handle_streams(amp, tx_l, tx_r, out).await;
+        handle_streams(workload, join_type, amp, tx_l, tx_r, out).await;
     }
 }
diff --git a/src/stream/benches/stream_hash_join_rt.rs b/src/stream/benches/stream_hash_join_rt.rs
@@ -35,7 +35,7 @@ fn bench_hash_join(c: &mut Criterion) {
     for amp in [10_000, 20_000, 30_000, 40_000, 100_000, 200_000, 400_000] {
         for workload in [HashJoinWorkload::NotInCache, HashJoinWorkload::InCache] {
             for join_type in [JoinType::Inner, JoinType::LeftOuter] {
-                let name = format!("hash_join_rt_{}_{}_{}", amp, workload, join_type);
+                let name = format!("hash_join_rt_{}_{}_{:#?}", amp, workload, join_type);
                 group.bench_function(&name, |b| {
                     b.to_async(&rt).iter_batched(
                         || block_on(setup_bench_stream_hash_join(amp, workload, join_type)),