fmt

Signed-off-by: Bugen Zhao <i@bugenzhao.com>
risingwavelabs · Feb 28, 2023 · e2f448b · e2f448b
1 parent 1c0c361
commit e2f448b
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/src/stream/src/executor/hash_join.rs b/src/stream/src/executor/hash_join.rs
@@ -779,9 +779,10 @@ impl<K: HashKey, S: StateStore, const T: JoinTypePrimitive> HashJoinExecutor<K,
             .positions(|idx| *idx == watermark.col_idx);
         let mut watermarks_to_emit = vec![];
         for idx in wm_in_jk {
-            let buffers = self.watermark_buffers.entry(idx).or_insert_with(|| {
-                BufferedWatermarks::with_ids([SideType::Left, SideType::Right])
-            });
+            let buffers = self
+                .watermark_buffers
+                .entry(idx)
+                .or_insert_with(|| BufferedWatermarks::with_ids([SideType::Left, SideType::Right]));
             if let Some(selected_watermark) = buffers.handle_watermark(side, watermark.clone()) {
                 let empty_indices = vec![];
                 let output_indices = side_update