rename

risingwavelabs · Jan 3, 2025 · 85a38fb · 85a38fb
1 parent bc39c60
commit 85a38fb
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/stream/src/executor/dispatch.rs b/src/stream/src/executor/dispatch.rs
@@ -398,7 +398,7 @@ impl StreamConsumer for DispatchExecutor {
     type BarrierStream = impl Stream<Item = StreamResult<Barrier>> + Send;
 
     fn execute(mut self: Box<Self>) -> Self::BarrierStream {
-        let barrier_batch_size = self
+        let max_additional_barrier_num = self
             .inner
             .context
             .config
@@ -437,7 +437,7 @@ impl StreamConsumer for DispatchExecutor {
                         let peek_more_barrier = b.mutation.is_none();
                         barrier_batch.push(b);
                         if peek_more_barrier {
-                            barrier_batch_size
+                            max_additional_barrier_num
                         } else {
                             0
                         }