Merge pull request #125 from ZSYTY/fix_20230322

LGTM
polardb · Mar 22, 2023 · d71a81c · d71a81c
2 parents 93e0379 + 6bd9327
commit d71a81c
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
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
@@ -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/...tor/src/main/java/com/alibaba/polardbx/executor/archive/writer/OSSBackFillWriterTask.java b/...tor/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;
     }