diff --git a/src/types/operator/operator.rs b/src/types/operator/operator.rs index 0eaa453df91..d114de8c950 100644 --- 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 {