chore(operator): apply max_batch_limit for async operator (#1641)

Signed-off-by: ClSlaid <cailue@bupt.edu.cn> Co-authored-by: Xuanwo <github@xuanwo.io>
apache · Mar 16, 2023 · dfb8d1c · dfb8d1c
1 parent 202ec70
commit dfb8d1c
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/types/operator/operator.rs b/src/types/operator/operator.rs
@@ -73,10 +73,8 @@ impl Operator {
  }
 
  pub(crate) fn from_inner(accessor: FusedAccessor) -> Self {
- Self {
- accessor,
- limit: 1000,
- }
+ let limit = accessor.info().max_batch_operations().unwrap_or(1000);
+ Self { accessor, limit }
  }
 
  pub(super) fn into_inner(self) -> FusedAccessor {