diff --git a/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java b/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java index 4d95aee..055f154 100644 --- a/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java +++ b/src/main/java/net/siegeln/cameleer/saas/config/AsyncConfig.java @@ -21,6 +21,7 @@ public class AsyncConfig { @Bean(name = "deploymentExecutor") public Executor deploymentExecutor() { var executor = new ThreadPoolTaskExecutor(); + // Core == max: no burst threads. Deployments beyond pool size queue (up to 25). executor.setCorePoolSize(runtimeConfig.getDeploymentThreadPoolSize()); executor.setMaxPoolSize(runtimeConfig.getDeploymentThreadPoolSize()); executor.setQueueCapacity(25); diff --git a/src/main/java/net/siegeln/cameleer/saas/log/ClickHouseConfig.java b/src/main/java/net/siegeln/cameleer/saas/log/ClickHouseConfig.java index 78cdaee..952102f 100644 --- a/src/main/java/net/siegeln/cameleer/saas/log/ClickHouseConfig.java +++ b/src/main/java/net/siegeln/cameleer/saas/log/ClickHouseConfig.java @@ -4,7 +4,6 @@ import org.springframework.beans.factory.annotation.Value; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; -import javax.sql.DataSource; import com.clickhouse.jdbc.ClickHouseDataSource; import java.util.Properties; @@ -15,7 +14,7 @@ public class ClickHouseConfig { private String url; @Bean(name = "clickHouseDataSource") - public DataSource clickHouseDataSource() throws Exception { + public ClickHouseDataSource clickHouseDataSource() throws Exception { var properties = new Properties(); return new ClickHouseDataSource(url, properties); }