Fix the problem that the appconn engine is not reused.

Author: JackChen0810

dss-appconn/linkis-appconn-engineplugin/src/main/resources/linkis-engineconn.properties

@@ -47,4 +47,7 @@ wds.linkis.mysql.is.encrypt=false
 wds.linkis.reflect.scan.package=org.apache.linkis,com.webank.wedatasphere.dss
 spring.spring.mvc.servlet.path=/api/rest_j/v1
 spring.spring.servlet.multipart.max-file-size=200MB
-spring.spring.servlet.multipart.max-request-size=200MB
+spring.spring.servlet.multipart.max-request-size=200MB
+
+wds.linkis.engineconn.support.parallelism=true
+wds.linkis.engineconn.max.free.time=0

dss-appconn/linkis-appconn-engineplugin/src/main/scala/org/apache/linkis/manager/engineplugin/appconn/conf/AppConnEngineConnConfiguration.scala

@@ -23,4 +23,6 @@ object AppConnEngineConnConfiguration {
 
   val GATEWAY_SPRING_APPLICATION = CommonVars("wds.linkis.gateway.spring.name", "dataworkcloud-gateway")
 
+  val CONCURRENT_LIMIT = CommonVars("wds.linkis.engineconn.appconn.conncurrent.limit", 100)
+
 }

dss-appconn/linkis-appconn-engineplugin/src/main/scala/org/apache/linkis/manager/engineplugin/appconn/executor/AppConnEngineConnExecutor.scala

@@ -18,7 +18,6 @@ package org.apache.linkis.manager.engineplugin.appconn.executor
 
 import java.util
 import java.util.Map
-
 import com.webank.wedatasphere.dss.appconn.core.AppConn
 import com.webank.wedatasphere.dss.appconn.core.ext.OnlyDevelopmentAppConn
 import com.webank.wedatasphere.dss.appconn.manager.AppConnManager
@@ -30,7 +29,7 @@ import com.webank.wedatasphere.dss.standard.app.sso.Workspace
 import com.webank.wedatasphere.dss.standard.common.desc.AppInstance
 import com.webank.wedatasphere.dss.standard.common.entity.ref.{AsyncResponseRef, DefaultRefFactory, ResponseRef}
 import org.apache.linkis.common.utils.{OverloadUtils, Utils}
-import org.apache.linkis.engineconn.computation.executor.execute.{ComputationExecutor, EngineExecutionContext}
+import org.apache.linkis.engineconn.computation.executor.execute.{ComputationExecutor, ConcurrentComputationExecutor, EngineExecutionContext}
 import org.apache.linkis.engineconn.launch.EngineConnServer
 import org.apache.linkis.governance.common.utils.GovernanceConstant
 import org.apache.linkis.manager.common.entity.resource.{CommonNodeResource, LoadResource, NodeResource}
@@ -45,10 +44,11 @@ import org.apache.linkis.protocol.engine.JobProgressInfo
 import org.apache.linkis.scheduler.executer.{ErrorExecuteResponse, ExecuteResponse, SuccessExecuteResponse}
 import org.apache.linkis.server.BDPJettyServerHelper
 import org.apache.commons.lang.StringUtils
+import org.apache.linkis.manager.engineplugin.appconn.conf.AppConnEngineConnConfiguration
 
 import scala.beans.BeanProperty
 
-class AppConnEngineConnExecutor(val id: Int) extends ComputationExecutor {
+class AppConnEngineConnExecutor(val id: Int) extends ConcurrentComputationExecutor {
 
   @BeanProperty
   var userWithCreator: UserWithCreator = _
@@ -172,6 +172,14 @@ class AppConnEngineConnExecutor(val id: Int) extends ComputationExecutor {
 
   override def getId(): String = "AppConnEngineExecutor_" + id
 
+  override def getConcurrentLimit: Int = {
+    AppConnEngineConnConfiguration.CONCURRENT_LIMIT.getValue
+  }
+
+  override def killAll(): Unit = {
+  }
+
+
 }
 object AppConnEngineConnExecutor {