fix: del duplicate sub

GreptimeTeam · Jan 16, 2025 · 459a3bd · 459a3bd
1 parent 8580bff
commit 459a3bd
Showing 1 changed file with 0 additions and 2 deletions.
diff --git a/src/flow/src/adapter/node_context.rs b/src/flow/src/adapter/node_context.rs
@@ -140,8 +140,6 @@ impl SourceSender {
                         len
                     );
                 }
-
-                self.send_buf_row_cnt.fetch_sub(len, Ordering::SeqCst);
                 row_cnt += len;
                 self.sender
                     .send(batch)