This is an automated email from the ASF dual-hosted git repository. wangzhen pushed a commit to branch dev-1.1.2 in repository https://gitbox.apache.org/repos/asf/incubator-linkis.git
commit 490333e837fefaee5ad30c4d52f9d6bc554dad39 Author: peacewong <[email protected]> AuthorDate: Sat May 7 10:47:34 2022 +0800 add engine conn status scan time conf --- .../acessible/executor/conf/AccessibleExecutorConfiguration.scala | 1 + .../acessible/executor/execution/AccessibleEngineConnExecution.scala | 4 ++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/conf/AccessibleExecutorConfiguration.scala b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/conf/AccessibleExecutorConfiguration.scala index dff9b7990..ce63912bd 100644 --- a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/conf/AccessibleExecutorConfiguration.scala +++ b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/conf/AccessibleExecutorConfiguration.scala @@ -45,6 +45,7 @@ object AccessibleExecutorConfiguration { val ENGINECONN_HEARTBEAT_TIME = CommonVars("wds.linkis.engineconn.heartbeat.time", new TimeType("2m")) + val ENGINECONN_STATUS_SCAN_TIME = CommonVars("wds.linkis.engineconn.status.scan.time", new TimeType("1m")) val ENABLE_MAINTAIN = CommonVars("wds.linkis.engineconn.maintain.enable", false) diff --git a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/execution/AccessibleEngineConnExecution.scala b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/execution/AccessibleEngineConnExecution.scala index 26943e2ca..a8a59d3c5 100644 --- a/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/execution/AccessibleEngineConnExecution.scala +++ b/linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/execution/AccessibleEngineConnExecution.scala @@ -74,7 +74,7 @@ class AccessibleEngineConnExecution extends EngineConnExecution with Logging { val maxFreeTimeVar = AccessibleExecutorConfiguration.ENGINECONN_MAX_FREE_TIME.getValue(context.getOptions) val maxFreeTimeStr = maxFreeTimeVar.toString val maxFreeTime = maxFreeTimeVar.toLong - logger.info("executorStatusChecker created， maxFreeTimeMills is " + maxFreeTime) + logger.info("executorStatusChecker created, maxFreeTimeMills is " + maxFreeTime) Utils.defaultScheduler.scheduleAtFixedRate(new Runnable { override def run(): Unit = Utils.tryAndWarn { val accessibleExecutor = ExecutorManager.getInstance.getReportExecutor match { @@ -104,7 +104,7 @@ class AccessibleEngineConnExecution extends EngineConnExecution with Logging { } } - }, 3 * 60 * 1000, AccessibleExecutorConfiguration.ENGINECONN_HEARTBEAT_TIME.getValue.toLong, TimeUnit.MILLISECONDS) + }, 3 * 60 * 1000, AccessibleExecutorConfiguration.ENGINECONN_STATUS_SCAN_TIME.getValue.toLong, TimeUnit.MILLISECONDS) } def requestManagerReleaseExecutor(msg: String): Unit = { --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
