From 0ebb4256abe6d7545a11ab7e368b0dd9bf69c192 Mon Sep 17 00:00:00 2001
From: hoslo <ys952572463@gmail.com>
Date: Thu, 27 Jun 2024 11:28:43 +0800
Subject: [PATCH] fix(core): write concurrent doesn't set correctly (#4816)

feat: fix write concurrent
---
 core/src/types/operator/operator_futures.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/types/operator/operator_futures.rs b/core/src/types/operator/operator_futures.rs
index 4d16680087d5..2efe12904115 100644
--- a/core/src/types/operator/operator_futures.rs
+++ b/core/src/types/operator/operator_futures.rs
@@ -300,7 +300,7 @@ impl<F: Future<Output = Result<()>>> FutureWrite<F> {
 
     /// Set the maximum concurrent write task amount.
     pub fn concurrent(self, v: usize) -> Self {
-        self.map(|(args, bs)| (args.with_chunk(v), bs))
+        self.map(|(args, bs)| (args.with_concurrent(v), bs))
     }
 
     /// Set the content type of option