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/29 06:12:07 UTC
[linkis] 02/06: EC debugging port supports configuration range #4712
This is an automated email from the ASF dual-hosted git repository.
casion pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/linkis.git
commit f9243f4be586294e1419f09840a2848ccbd6e6ed
Author: peacewong <wp...@gmail.com>
AuthorDate: Tue Jun 27 22:15:09 2023 +0800
EC debugging port supports configuration range #4712
---
.../linkis/governance/common/conf/GovernanceCommonConf.scala | 2 ++
.../apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala | 7 ++++++-
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernanceCommonConf.scala b/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernanceCommonConf.scala
index 67aab4bd4..a2b44d2d8 100644
--- a/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernanceCommonConf.scala
+++ b/linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/conf/GovernanceCommonConf.scala
@@ -48,6 +48,8 @@ object GovernanceCommonConf {
val ENGINE_CONN_PORT_RANGE = CommonVars("wds.linkis.engineconn.port.range", "-")
+ val ENGINE_CONN_DEBUG_PORT_RANGE = CommonVars("wds.linkis.engineconn.debug.port.range", "-")
+
val MANAGER_SERVICE_NAME =
CommonVars(
"wds.linkis.engineconn.manager.name",
diff --git a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-core/src/main/scala/org/apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-core/src/main/scala/org/apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala
index b6a4bee0a..672c0e8ac 100644
--- a/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-core/src/main/scala/org/apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala
+++ b/linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-core/src/main/scala/org/apache/linkis/ecm/core/launch/ProcessEngineConnLaunch.scala
@@ -102,7 +102,12 @@ trait ProcessEngineConnLaunch extends EngineConnLaunch with Logging {
case HIVE_CONF_DIR => putIfExists(HIVE_CONF_DIR)
case JAVA_HOME => putIfExists(JAVA_HOME)
case RANDOM_PORT =>
- environment.put(RANDOM_PORT.toString, PortUtils.findAvailPort().toString)
+ environment.put(
+ RANDOM_PORT.toString,
+ PortUtils
+ .findAvailPortByRange(GovernanceCommonConf.ENGINE_CONN_DEBUG_PORT_RANGE.getValue)
+ .toString
+ )
case PREFER_IP_ADDRESS =>
environment.put(PREFER_IP_ADDRESS.toString, Configuration.PREFER_IP_ADDRESS.toString)
case ENGINECONN_ENVKEYS =>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@linkis.apache.org
For additional commands, e-mail: commits-help@linkis.apache.org