You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@linkis.apache.org by ca...@apache.org on 2023/06/09 10:15:50 UTC
[linkis] branch dev-1.4.0 updated: Fix ENGINE_TASK_EXPIRE_TIME ClassCastException bug (#4614)
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 <18...@163.com>
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: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org