This is an automated email from the ASF dual-hosted git repository. peacewong pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/linkis.git
commit 0453b072de83104cddf9098f559607abf0264a9a Merge: b6af5f0c3 9f4a9c881 Author: peacewong <[email protected]> AuthorDate: Sun Nov 19 21:51:03 2023 +0800 [Feature] Entrance support ha and failover task [Feature] Entrance support ha and failover task .../org/apache/linkis/common/ServiceInstance.scala | 18 +- .../linkis/common/utils/CodeAndRunTypeUtils.scala | 11 +- .../linkis/server/conf/ServerConfiguration.scala | 3 + .../linkis/protocol/constants/TaskConstant.java | 1 + .../linkis/protocol/engine/JobInstance.scala | 19 +- .../linkis/protocol/utils/ZuulEntranceUtils.scala | 2 +- .../linkis/scheduler/queue/AbstractGroup.scala | 7 + .../scheduler/queue/SchedulerEventState.scala | 4 + .../queue/fifoqueue/FIFOUserConsumer.scala | 21 +- .../governance/common/entity/job/JobRequest.java | 11 + .../common/protocol/job/JobReqProcotol.scala | 7 + .../service/TaskExecutionServiceImpl.scala | 2 +- .../linkis-entrance/pom.xml | 6 + .../entrance/conf/EntranceSpringConfiguration.java | 4 +- .../entrance/constant/ServiceNameConsts.java | 2 + .../errorcode/EntranceErrorCodeSummary.java | 6 +- .../entrance/restful/EntranceLabelRestfulApi.java | 20 + .../entrance/restful/EntranceRestfulApi.java | 461 +++++++++++++++----- .../entrance/server/DefaultEntranceServer.java | 16 +- .../entrance/server/EntranceFailoverJobServer.java | 180 ++++++++ .../apache/linkis/entrance/EntranceServer.scala | 480 +++++++++++++++++++-- .../entrance/conf/EntranceConfiguration.scala | 40 ++ .../interceptor/impl/CustomVariableUtils.scala | 2 +- .../interceptor/impl/UserCreatorIPCheckUtils.scala | 2 +- .../scheduler/EntranceFIFOUserConsumer.scala | 70 +++ .../entrance/scheduler/EntranceGroupFactory.scala | 39 +- .../EntranceParallelConsumerManager.scala | 101 +++++ .../scheduler/EntranceSchedulerContext.scala | 5 + .../linkis/entrance/utils/JobHistoryHelper.scala | 152 ++++++- .../linkis/templates/configmap-linkis-config.yaml | 9 +- .../package/conf/linkis-cg-entrance.properties | 4 +- .../package/conf/linkis-mg-gateway.properties | 4 +- .../conf/OrchestratorConfiguration.scala | 2 +- .../linkis/jobhistory/dao/JobHistoryMapper.java | 24 ++ .../resources/mapper/mysql/JobHistoryMapper.xml | 23 + .../mapper/postgresql/JobHistoryMapper.xml | 22 + .../jobhistory/service/JobHistoryQueryService.java | 2 + .../service/impl/JobHistoryQueryServiceImpl.scala | 28 +- .../linkis-gateway-server-support/pom.xml | 7 + .../ujes/parser/EntranceRequestGatewayParser.scala | 59 ++- .../http/SpringCloudGatewayHttpRequest.scala | 4 +- 41 files changed, 1654 insertions(+), 226 deletions(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
