This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
The following commit(s) were added to refs/heads/dev-1.4.0 by this push:
new 1d1abfc1b Fix ENGINE_TASK_EXPIRE_TIME ClassCastException bug (#4614)
1d1abfc1b is described below
commit 1d1abfc1b38bcd859fab9e5f06899826f7f120b3
Author: ChengJie1053 <[email protected]>
AuthorDate: Fri Jun 9 18:15:42 2023 +0800
Fix ENGINE_TASK_EXPIRE_TIME ClassCastException bug (#4614)
---
.../elasticsearch/executor/ElasticSearchEngineConnExecutor.java | 3 ++-
.../linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
diff --git
a/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
b/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
index 8d6b7e6ed..bb7c0fce4 100644
---
a/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
+++
b/linkis-engineconn-plugins/elasticsearch/src/main/java/org/apache/linkis/engineplugin/elasticsearch/executor/ElasticSearchEngineConnExecutor.java
@@ -74,7 +74,8 @@ public class ElasticSearchEngineConnExecutor extends
ConcurrentComputationExecut
private Cache<String, ElasticSearchExecutor> elasticSearchExecutorCache =
CacheBuilder.newBuilder()
.expireAfterAccess(
- (Long) EngineConnConf.ENGINE_TASK_EXPIRE_TIME().getValue(),
TimeUnit.MILLISECONDS)
+
Long.valueOf(EngineConnConf.ENGINE_TASK_EXPIRE_TIME().getValue().toString()),
+ TimeUnit.MILLISECONDS)
.removalListener(
new RemovalListener<String, ElasticSearchExecutor>() {
@Override
diff --git
a/linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java
b/linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java
index c7533c305..64b9be02e 100644
---
a/linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java
+++
b/linkis-engineconn-plugins/trino/src/main/java/org/apache/linkis/engineplugin/trino/executor/TrinoEngineConnExecutor.java
@@ -97,7 +97,8 @@ public class TrinoEngineConnExecutor extends
ConcurrentComputationExecutor {
private Cache<String, ClientSession> clientSessionCache =
CacheBuilder.newBuilder()
.expireAfterAccess(
- (Long) EngineConnConf.ENGINE_TASK_EXPIRE_TIME().getValue(),
TimeUnit.MILLISECONDS)
+
Long.valueOf(EngineConnConf.ENGINE_TASK_EXPIRE_TIME().getValue().toString()),
+ TimeUnit.MILLISECONDS)
.maximumSize(EngineConnConstant.MAX_TASK_NUM())
.build();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
