This is an automated email from the ASF dual-hosted git repository.
azexin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new d51f384e5f3 Improve PR 27251 (#27291)
d51f384e5f3 is described below
commit d51f384e5f373211bbaf66f16837fe1a900da73b
Author: Hongsheng Zhong <[email protected]>
AuthorDate: Wed Jul 19 14:03:45 2023 +0800
Improve PR 27251 (#27291)
---
kernel/data-pipeline/core/pom.xml | 8 ++++----
.../data/pipeline/common/sqlbuilder/PipelineImportSQLBuilder.java | 7 +------
2 files changed, 5 insertions(+), 10 deletions(-)
diff --git a/kernel/data-pipeline/core/pom.xml
b/kernel/data-pipeline/core/pom.xml
index 363046c1914..8cb5579f15d 100644
--- a/kernel/data-pipeline/core/pom.xml
+++ b/kernel/data-pipeline/core/pom.xml
@@ -77,6 +77,10 @@
<artifactId>HikariCP</artifactId>
<scope>compile</scope>
</dependency>
+ <dependency>
+ <groupId>com.github.ben-manes.caffeine</groupId>
+ <artifactId>caffeine</artifactId>
+ </dependency>
<dependency>
<groupId>org.apache.shardingsphere</groupId>
@@ -96,9 +100,5 @@
<version>${project.version}</version>
<scope>test</scope>
</dependency>
- <dependency>
- <groupId>com.github.ben-manes.caffeine</groupId>
- <artifactId>caffeine</artifactId>
- </dependency>
</dependencies>
</project>
diff --git
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/sqlbuilder/PipelineImportSQLBuilder.java
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/sqlbuilder/PipelineImportSQLBuilder.java
index 2291f793964..7e5c1459658 100644
---
a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/sqlbuilder/PipelineImportSQLBuilder.java
+++
b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/common/sqlbuilder/PipelineImportSQLBuilder.java
@@ -50,12 +50,7 @@ public final class PipelineImportSQLBuilder {
public PipelineImportSQLBuilder(final DatabaseType databaseType) {
dialectSQLBuilder =
DatabaseTypedSPILoader.getService(DialectPipelineSQLBuilder.class,
databaseType);
sqlSegmentBuilder = new PipelineSQLSegmentBuilder(databaseType);
- sqlCache = buildPipelineCache();
- }
-
- private Cache<String, String> buildPipelineCache() {
- Caffeine<Object, Object> result =
Caffeine.newBuilder().initialCapacity(128).maximumSize(1024).softValues();
- return result.build();
+ sqlCache =
Caffeine.newBuilder().initialCapacity(16).maximumSize(1024).build();
}
/**