diff --git a/polardbx-common/src/main/java/com/alibaba/polardbx/common/properties/ConnectionParams.java b/polardbx-common/src/main/java/com/alibaba/polardbx/common/properties/ConnectionParams.java
index 06a9d950e..c167a915f 100644
--- a/polardbx-common/src/main/java/com/alibaba/polardbx/common/properties/ConnectionParams.java
+++ b/polardbx-common/src/main/java/com/alibaba/polardbx/common/properties/ConnectionParams.java
@@ -2662,7 +2662,7 @@ public static class ConnectionParamValues {
         true);
 
     public static final IntConfigParam MAX_SESSION_PREPARED_STMT_COUNT = new IntConfigParam(
-        ConnectionProperties.MAX_SESSION_PREPARED_STMT_COUNT, 0, Integer.MAX_VALUE, 100, true);
+        ConnectionProperties.MAX_SESSION_PREPARED_STMT_COUNT, 0, Integer.MAX_VALUE, 256, true);
 
     public static final BooleanConfigParam ENABLE_PARTITIONS_HEATMAP_COLLECTION = new BooleanConfigParam(
         ConnectionProperties.ENABLE_PARTITIONS_HEATMAP_COLLECTION, true, true);
diff --git a/polardbx-executor/src/main/java/com/alibaba/polardbx/executor/archive/writer/OSSBackFillWriterTask.java b/polardbx-executor/src/main/java/com/alibaba/polardbx/executor/archive/writer/OSSBackFillWriterTask.java
index 0a09326d2..0e6ad1c6f 100644
--- a/polardbx-executor/src/main/java/com/alibaba/polardbx/executor/archive/writer/OSSBackFillWriterTask.java
+++ b/polardbx-executor/src/main/java/com/alibaba/polardbx/executor/archive/writer/OSSBackFillWriterTask.java
@@ -19,13 +19,14 @@
 import com.alibaba.polardbx.common.CrcAccumulator;
 import com.alibaba.polardbx.common.Engine;
 import com.alibaba.polardbx.common.OrderInvariantHasher;
-import com.alibaba.polardbx.common.OrderInvariantHasher;
+import com.alibaba.polardbx.common.async.AsyncTask;
 import com.alibaba.polardbx.common.jdbc.ParameterContext;
 import com.alibaba.polardbx.common.orc.OrcBloomFilter;
 import com.alibaba.polardbx.common.oss.OSSMetaLifeCycle;
 import com.alibaba.polardbx.common.utils.TStringUtil;
 import com.alibaba.polardbx.executor.ddl.job.meta.FileStorageBackFillAccessor;
 import com.alibaba.polardbx.executor.gsi.GsiBackfillManager;
+import com.alibaba.polardbx.executor.mpp.deploy.ServiceProvider;
 import com.alibaba.polardbx.gms.engine.FileSystemUtils;
 import com.alibaba.polardbx.common.oss.access.OSSKey;
 import com.alibaba.polardbx.common.properties.ConnectionParams;
@@ -393,8 +394,8 @@ public synchronized void flush(ExecutionContext ec) {
         }
 
         // submit async flush task
-        PriorityWorkQueue.getInstance()
-            .executeWithContext(flushTask, PriorityFIFOTask.TaskPriority.OSS_FLUSH);
+        ServiceProvider.getInstance().getServerExecutor()
+            .submit(this.logicalTable, this.taskId.toString(), AsyncTask.build(flushTask));
 
         totalRows = 0L;
     }