This is an automated email from the ASF dual-hosted git repository.
peacewong pushed a change to branch dev-1.4.0
in repository https://gitbox.apache.org/repos/asf/linkis.git
from a3aec9e09 feat(pom): fix build with jdk17 for default profiles (#4480)
add be9d230f0 feat: Reduce scala module: linkis-mange#4192
add 252a00d17 feat: Reduce scala module: linkis-mange#4192
add 7c9870631 feat: Reduce scala module: linkis-mange#4192
add 4a1a41356 feat: Reduce scala module: linkis-mange#4192
add 5c2269e92 feat: Reduce scala module: linkis-mange#4192
add ab40b5df8 feat: Reduce scala module: linkis-mange#4192
add ffe42eee6 feat: Reduce scala module: linkis-mange#4192
add f1e7d8ad0 feat: Reduce scala module: linkis-manage modify exception
#4192
add 0f69de9d0 feat: Reduce scala module: linkis-manage modify exception
#4192
add f4921b45e feat: Reduce scala module: linkis-manage modify exception
#4192
add 5665641eb feat: Reduce scala module: linkis-manage modify exception
#4192
add 7fa9be049 feat: Reduce scala module: linkis-manage modify exception
#4192
add ca2fe91db feat: Reduce scala module: linkis-manage modify exception
#4192
add 40fca226d feat: Reduce scala module: linkis-manage modify exception
#4192
add 634fd03c8 feat: Reduce scala module: linkis-manage modify exception
#4192
add cbff5fa69 feat: Reduce scala module: linkis-manage modify exception
#4192
add 02b2dab74 feat: Reduce scala module: linkis-manage modify exception
#4192
add a99d3d715 feat: Reduce scala module: linkis-manage modify exception
#4192
new 5b7fd7bd8 Reduce mixed language module linkismange #4463
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../linkis/common/exception/ErrorException.java | 2 +-
.../linkis/common/exception/FatalException.java | 2 +-
.../common/exception/LinkisRetryException.java | 4 +-
.../governance/common/utils/ECPathUtils.java | 53 ++
.../exception/GovernanceErrorException.scala | 5 +-
.../governance/common/utils/ECPathUtils.scala | 58 --
.../ecm/server/operator/EngineConnLogOperator.java | 219 +++++
.../server/operator/EngineConnYarnLogOperator.java | 147 ++++
.../ecm/server/exception/ECMErrorException.scala | 11 +-
.../server/operator/EngineConnLogOperator.scala | 191 -----
.../operator/EngineConnYarnLogOperator.scala | 124 ---
.../impl/AbstractEngineConnLaunchService.scala | 5 +-
.../service/impl/DefaultECMRegisterService.scala | 8 +-
.../service/impl/DefaultOperateService.scala | 24 +-
.../impl/ProcessEngineConnLaunchService.scala | 2 +-
.../operator/OperableOnceEngineConnOperator.java | 92 +++
.../operator/OperableOnceEngineConnOperator.scala | 72 --
.../service/TaskExecutionServiceImpl.scala | 13 +-
.../impl/EngineConnApplicationInfoOperator.java | 56 ++
.../execution/AccessibleEngineConnExecution.scala | 2 +-
.../impl/EngineConnApplicationInfoOperator.scala | 50 --
.../executor/service/DefaultManagerService.scala | 3 +-
.../executor/service/DefaultOperateService.scala | 24 +-
.../service/EngineConnTimedLockService.scala | 12 +-
.../acessible/executor/service/LockService.scala | 7 +-
.../callback/hook/CallbackEngineConnHook.scala | 4 +-
.../callback/service/EngineConnCallback.scala | 2 +-
.../exception/EngineConnPluginErrorException.scala | 7 +-
.../entrance/restful/EntranceRestfulApi.java | 2 +-
.../loader/EngineConnPluginLoaderConf.java | 44 +
.../loaders/CacheablesEngineConnPluginLoader.java | 3 +-
.../loaders/DefaultEngineConnPluginLoader.java | 27 +-
.../BmlEngineConnPluginResourceLoader.java | 4 +-
.../server/conf/EngineConnPluginConfiguration.java | 42 +
.../interceptor/EngineConnLaunchInterceptor.java} | 14 +-
.../loader/EngineConnPluginsLoaderFactory.java} | 19 +-
.../AbstractEngineConnBmlResourceGenerator.java | 134 ++++
.../DefaultEngineConnBmlResourceGenerator.java | 109 +++
.../localize/EngineConnBmlResourceGenerator.java} | 12 +-
.../localize/EngineConnLocalizeResource.java} | 12 +-
.../localize/EngineConnLocalizeResourceImpl.java | 69 ++
.../service/DefaultEngineConnLaunchService.java | 106 +++
.../DefaultEngineConnResourceFactoryService.java | 80 ++
.../service/DefaultEngineConnResourceService.java | 351 ++++++++
.../server/service/EngineConnLaunchService.java} | 15 +-
.../service/EngineConnResourceFactoryService.java} | 19 +-
.../server/service/EngineConnResourceRequest.java} | 37 +-
.../server/service/EngineConnResourceService.java | 43 +
.../service/GetEngineConnResourceRequest.java} | 15 +-
.../RefreshAllEngineConnResourceRequest.java} | 16 +-
.../service/RefreshEngineConnResourceRequest.java} | 15 +-
.../service/impl/EnginePluginAdminServiceImpl.java | 7 +-
.../linkis/manager/am/conf/AMConfiguration.java | 125 +++
.../ApplicationManagerSpringConfiguration.java} | 19 +-
.../manager/am/conf/ConfigurationMapCache.java | 69 ++
.../DefaultEngineConnConfigurationService.java | 72 ++
.../am/conf/EngineConnConfigurationService.java} | 9 +-
.../linkis/manager/am/conf/ManagerMonitorConf.java | 45 ++
.../am/converter/DefaultMetricsConverter.java | 140 ++++
.../manager/am/exception/AMErrorException.java | 10 +-
.../linkis/manager/am/label/AMLabelChecker.java | 56 ++
.../linkis/manager/am/label/AMLabelFilter.java | 59 ++
.../am/label/DefaultManagerLabelService.java | 63 ++
.../manager/am/label/EngineReuseLabelChooser.java} | 11 +-
.../am/label/MultiUserEngineReuseLabelChooser.java | 104 +++
.../manager/am/locker/DefaultEngineNodeLocker.java | 73 ++
.../manager/am/locker/EngineNodeLocker.java} | 13 +-
.../manager/am/manager/DefaultEMNodeManager.java | 218 +++++
.../am/manager/DefaultEngineNodeManager.java | 346 ++++++++
.../linkis/manager/am/manager/EMNodeManager.java | 73 ++
.../manager/am/manager/EngineNodeManager.java | 67 ++
.../manager/am/pointer/AbstractNodePointer.java | 98 +++
.../manager/am/pointer/DefaultEMNodPointer.java | 110 +++
.../am/pointer/DefaultEngineNodPointer.java | 82 ++
.../am/pointer/DefaultNodePointerBuilder.java | 24 +-
.../am/recycle/AssignNodeRuleExecutor.java} | 27 +-
.../manager/am/recycle/RecyclingRuleExecutor.java} | 13 +-
.../linkis/manager/am/restful/EMRestfulApi.java | 25 +-
.../manager/am/restful/EngineRestfulApi.java | 4 +-
.../am/selector/DefaultECAvailableRule.java} | 22 +-
.../manager/am/selector/DefaultNodeSelector.java | 75 ++
.../manager/am/selector/ECAvailableRule.java} | 12 +-
.../linkis/manager/am/selector/NodeSelector.java} | 15 +-
.../am/selector/rule/AvailableNodeSelectRule.java | 68 ++
.../selector/rule/ConcurrencyNodeSelectRule.java} | 22 +-
.../am/selector/rule/HotspotExclusionRule.java} | 56 +-
.../am/selector/rule/NewECMStandbyRule.java | 82 ++
.../manager/am/selector/rule/NodeSelectRule.java} | 9 +-
.../am/selector/rule/ResourceNodeSelectRule.java | 120 +++
.../am/selector/rule/ScoreNodeSelectRule.java | 70 ++
.../am/selector/rule/TaskInfoNodeSelectRule.java | 73 ++
.../manager/am/service/EMEngineService.java} | 27 +-
.../linkis/manager/am/service/EngineService.java} | 11 +-
.../manager/am/service/HeartbeatService.java} | 9 +-
.../cache/ConfCacheRemoveBroadcastListener.java | 75 ++
.../am/service/em/DefaultECMOperateService.java} | 31 +-
.../am/service/em/DefaultEMEngineService.java | 228 ++++++
.../am/service/em/DefaultEMInfoService.java | 140 ++++
.../am/service/em/DefaultEMRegisterService.java | 124 +++
.../am/service/em/DefaultEMUnregisterService.java | 98 +++
.../em/ECMOperateService.java} | 17 +-
.../manager/am/service/em/EMInfoService.java} | 22 +-
.../manager/am/service/em/EMRegisterService.java} | 14 +-
.../em/EMUnregisterService.java} | 18 +-
.../am/service/engine/AbstractEngineService.java | 26 +-
.../engine/DefaultEngineAskEngineService.java | 192 +++++
.../engine/DefaultEngineConnCanKillService.java | 196 +++++
.../service/engine/DefaultEngineCreateService.java | 433 ++++++++++
.../service/engine/DefaultEngineInfoService.java | 142 ++++
.../engine/DefaultEngineOperateService.java} | 29 +-
.../engine/DefaultEngineRecycleService.java | 92 +++
.../service/engine/DefaultEngineReuseService.java | 257 ++++++
.../service/engine/DefaultEngineStopService.java | 316 ++++++++
.../engine/DefaultEngineSwitchService.java} | 18 +-
.../am/service/engine/EngineAskEngineService.java} | 11 +-
.../service/engine/EngineConnCanKillService.java} | 12 +-
.../engine/EngineConnStatusCallbackService.java} | 11 +-
.../am/service/engine/EngineCreateService.java} | 18 +-
.../am/service/engine/EngineInfoService.java | 52 ++
.../am/service/engine/EngineOperateService.java} | 17 +-
.../am/service/engine/EngineRecycleService.java} | 15 +-
.../am/service/engine/EngineReuseService.java} | 17 +-
.../am/service/engine/EngineStopService.java | 61 ++
.../am/service/engine/EngineSwitchService.java} | 14 +-
.../am/service/heartbeat/AMHeartbeatService.java | 85 ++
.../DefaultEngineConnStatusCallbackService.java | 39 +-
.../am/service/monitor/NodeHeartbeatMonitor.java | 372 +++++++++
.../apache/linkis/manager/am/util/LinkisUtils.java | 248 ++++++
.../apache/linkis/manager/am/utils/AMUtils.java | 338 ++++++++
.../manager/am/utils/DefaultRetryHandler.java | 122 +++
.../linkis/manager/am/utils/RetryHandler.java} | 27 +-
.../linkis/manager/am/vo/AMEngineNodeVo.java | 6 +-
.../org/apache/linkis/manager/am/vo/EMNodeVo.java | 6 +-
.../linkis/manager/label/LabelManagerUtils.java} | 26 +-
.../manager/label/conf/LabelManagerConf.java} | 12 +-
.../label/score/DefaultNodeLabelScorer.java | 201 +++++
.../label/score/LabelScoreServiceInstance.java} | 38 +-
.../manager/label/score/NodeLabelScorer.java} | 35 +-
.../label/service/NodeLabelAddService.java} | 12 +-
.../label/service/NodeLabelRemoveService.java} | 11 +-
.../manager/label/service/NodeLabelService.java | 83 ++
.../label/service/ResourceLabelService.java} | 32 +-
.../manager/label/service/UserLabelService.java} | 20 +-
.../service/impl/DefaultNodeLabelAddService.java | 69 ++
.../impl/DefaultNodeLabelRemoveService.java | 82 ++
.../service/impl/DefaultNodeLabelService.java | 467 +++++++++++
.../service/impl/DefaultResourceLabelService.java | 161 ++++
.../service/impl/DefaultUserLabelService.java | 167 ++++
.../linkis/manager/rm/conf/ResourceStatus.java | 4 +-
.../linkis/manager/rm/domain/RMLabelContainer.java | 11 +-
.../manager/rm/entity/LabelResourceMapping.java | 68 ++
.../manager/rm/entity/ResourceOperationType.java} | 9 +-
.../service/impl/ExternalResourceServiceImpl.java | 11 +-
.../manager/rm/external/yarn/YarnAppInfo.java | 78 ++
.../rm/external/yarn/YarnResourceRequester.java | 450 +++++++++++
.../manager/rm/message/RMMessageService.java | 75 ++
.../linkis/manager/rm/restful/RMMonitorRest.java | 872 ++++++++++++++++++++
.../manager/rm/service/LabelResourceService.java} | 33 +-
.../manager/rm/service/RequestResourceService.java | 422 ++++++++++
.../manager/rm/service/ResourceLockService.java | 95 +++
.../manager/rm/service/ResourceManager.java} | 41 +-
.../manager/rm/service/impl/ChangeType.java} | 28 +-
.../service/impl/DefaultReqResourceService.java} | 21 +-
.../rm/service/impl/DefaultResourceManager.java | 875 ++++++++++++++++++++
.../impl/DriverAndYarnReqResourceService.java | 151 ++++
.../rm/service/impl/LabelResourceServiceImpl.java | 102 +++
.../rm/service/impl/ResourceLogService.java | 222 ++++++
.../rm/service/impl/UserResourceService.java | 128 +++
.../apache/linkis/manager/rm/utils/RMUtils.java | 283 +++++++
.../linkis/manager/rm/utils/UserConfiguration.java | 210 +++++
.../service/common/label/LabelChecker.java} | 14 +-
.../manager/service/common/label/LabelFilter.java} | 8 +-
.../service/common/label/ManagerLabelService.java} | 11 +-
.../service/common/metrics/MetricsConverter.java | 55 ++
.../service/common/pointer/EMNodPointer.java} | 20 +-
.../service/common/pointer/EngineNodePointer.java} | 24 +-
.../service/common/pointer/NodePointer.java} | 32 +-
.../common/pointer/NodePointerBuilder.java} | 15 +-
.../loader/EngineConnPluginLoaderConf.scala | 50 --
.../conf/EngineConnPluginConfiguration.scala | 42 -
.../AbstractEngineConnBmlResourceGenerator.scala | 125 ---
.../DefaultEngineConnBmlResourceGenerator.scala | 109 ---
.../service/DefaultEngineConnLaunchService.scala | 90 ---
.../DefaultEngineConnResourceFactoryService.scala | 64 --
.../service/DefaultEngineConnResourceService.scala | 294 -------
.../server/service/EngineConnResourceService.scala | 78 --
.../linkis/manager/am/conf/AMConfiguration.scala | 118 ---
.../manager/am/conf/ConfigurationMapCache.scala | 64 --
.../am/conf/EngineConnConfigurationService.scala | 70 --
.../manager/am/conf/ManagerMonitorConf.scala | 43 -
.../am/converter/DefaultMetricsConverter.scala | 102 ---
.../linkis/manager/am/label/AMLabelChecker.scala | 50 --
.../linkis/manager/am/label/AMLabelFilter.scala | 56 --
.../am/label/DefaultManagerLabelService.scala | 72 --
.../label/MultiUserEngineReuseLabelChooser.scala | 83 --
.../am/locker/DefaultEngineNodeLocker.scala | 61 --
.../manager/am/manager/DefaultEMNodeManager.scala | 193 -----
.../am/manager/DefaultEngineNodeManager.scala | 317 --------
.../linkis/manager/am/manager/EMNodeManager.scala | 71 --
.../manager/am/manager/EngineNodeManager.scala | 82 --
.../manager/am/pointer/AbstractNodePointer.scala | 83 --
.../manager/am/pointer/DefaultEMNodPointer.scala | 83 --
.../am/pointer/DefaultEngineNodPointer.scala | 68 --
.../manager/am/selector/DefaultNodeSelector.scala | 75 --
.../manager/am/selector/ECAvailableRule.scala | 55 --
.../am/selector/rule/AvailableNodeSelectRule.scala | 60 --
.../am/selector/rule/NewECMStandbyRule.scala | 83 --
.../am/selector/rule/OverLoadNodeSelectRule.scala | 66 --
.../am/selector/rule/ResourceNodeSelectRule.scala | 101 ---
.../am/selector/rule/ScoreNodeSelectRule.scala | 55 --
.../am/selector/rule/TaskInfoNodeSelectRule.scala | 63 --
.../cache/ConfCacheRemoveBroadcastListener.scala | 70 --
.../am/service/em/DefaultECMOperateService.scala | 36 -
.../am/service/em/DefaultEMEngineService.scala | 209 -----
.../am/service/em/DefaultEMInfoService.scala | 124 ---
.../am/service/em/DefaultEMRegisterService.scala | 121 ---
.../am/service/em/DefaultEMUnregisterService.scala | 89 ---
.../manager/am/service/em/ECMOperateService.scala | 27 -
.../manager/am/service/em/EMRegisterService.scala | 33 -
.../engine/DefaultEngineAskEngineService.scala | 170 ----
.../engine/DefaultEngineConnCanKillService.scala | 173 ----
.../engine/DefaultEngineCreateService.scala | 404 ----------
.../service/engine/DefaultEngineInfoService.scala | 145 ----
.../engine/DefaultEngineRecycleService.scala | 82 --
.../service/engine/DefaultEngineReuseService.scala | 219 -----
.../service/engine/DefaultEngineStopService.scala | 292 -------
.../service/engine/EngineConnCanKillService.scala | 26 -
.../am/service/engine/EngineInfoService.scala | 50 --
.../am/service/engine/EngineKillService.scala | 31 -
.../am/service/engine/EngineOperateService.scala | 33 -
.../am/service/engine/EngineStopService.scala | 69 --
.../am/service/heartbeat/AMHeartbeatService.scala | 83 --
.../am/service/monitor/NodeHeartbeatMonitor.scala | 493 ------------
.../apache/linkis/manager/am/utils/AMUtils.scala | 305 -------
.../manager/label/conf/LabelManagerConf.scala | 27 -
.../label/score/DefaultNodeLabelScorer.scala | 182 -----
.../label/service/NodeLabelRemoveService.scala | 26 -
.../manager/label/service/NodeLabelService.scala | 93 ---
.../service/impl/DefaultNodeLabelAddService.scala | 56 --
.../impl/DefaultNodeLabelRemoveService.scala | 75 --
.../service/impl/DefaultNodeLabelService.scala | 411 ----------
.../service/impl/DefaultResourceLabelService.scala | 162 ----
.../service/impl/DefaultUserLabelService.scala | 122 ---
.../manager/rm/entity/LabelResourceMap.scala | 52 --
.../manager/rm/external/yarn/YarnAppInfo.scala | 29 -
.../rm/external/yarn/YarnResourceRequester.scala | 440 ----------
.../manager/rm/message/RMMessageService.scala | 68 --
.../linkis/manager/rm/restful/RMMonitorRest.scala | 842 --------------------
.../rm/service/RequestResourceService.scala | 399 ----------
.../manager/rm/service/ResourceLockService.scala | 80 --
.../rm/service/impl/DefaultResourceManager.scala | 881 ---------------------
.../impl/DriverAndYarnReqResourceService.scala | 121 ---
.../rm/service/impl/LabelResourceServiceImpl.scala | 100 ---
.../rm/service/impl/ResourceLogService.scala | 234 ------
.../rm/service/impl/UserResourceService.scala | 114 ---
.../apache/linkis/manager/rm/utils/RMUtils.scala | 256 ------
.../manager/rm/utils/UserConfiguration.scala | 174 ----
.../service/common/metrics/MetricsConverter.scala | 57 --
.../service/common/pointer/EngineNodePointer.scala | 34 -
.../common/pointer/NodePointerBuilder.scala | 28 -
...est.java => ECResourceInfoLinkisUtilsTest.java} | 2 +-
.../label/exception/LabelErrorException.java | 10 +-
.../manager/common/conf/ManagerCommonConf.java} | 21 +-
.../manager/common/conf/RMConfiguration.java | 114 +++
.../manager/common/entity/node/AMEMNode.java | 6 +-
.../manager/common/entity/node/AMEngineNode.java | 8 +-
.../manager/common/entity/node/LabelNode.java | 4 +-
.../common/entity/recycle/AssignEMNodeRule.java | 26 +-
.../common/entity/recycle/AssignNodeRule.java | 26 +-
.../common/entity/recycle/AssignUserRule.java} | 16 +-
.../common/entity/recycle/RecyclingRule.java} | 10 +-
.../common/entity/resource/CPUResource.java | 132 +++
.../entity/resource/DriverAndYarnResource.java | 222 ++++++
.../common/entity/resource/InstanceResource.java | 37 +-
.../entity/resource/LoadInstanceResource.java | 161 ++++
.../common/entity/resource/LoadResource.java | 129 +++
.../common/entity/resource/MemoryResource.java | 120 +++
.../manager/common/entity/resource/Resource.java | 134 ++++
.../common/entity/resource/SpecialResource.java | 355 +++++++++
.../entity/resource/UserAvailableResource.java | 21 +-
.../common/entity/resource/YarnResource.java | 176 ++++
.../manager/common/exception/RMErrorException.java | 10 +-
.../manager/common/monitor/ManagerMonitor.java} | 4 +-
.../linkis/manager/common/operator/Operator.java | 56 ++
.../manager/common/operator/OperatorFactory.java} | 16 +-
.../common/operator/OperatorFactoryImpl.java | 72 ++
.../manager/common/protocol/EngineLock.java} | 6 +-
.../manager/common/protocol/OperateRequest.java} | 31 +-
.../manager/common/protocol/OperateResponse.java} | 10 +-
.../common/protocol/RequestEngineLock.java} | 39 +-
.../common/protocol/RequestEngineUnlock.java} | 20 +-
.../common/protocol/RequestManagerUnlock.java | 59 ++
.../ResponseEngineLock.java} | 40 +-
.../common/protocol/ResponseEngineUnlock.java} | 20 +-
.../common/protocol/em/ECMOperateRequest.java | 51 ++
.../common/protocol/em/ECMOperateResponse.java} | 42 +-
.../protocol/em/EMResourceRegisterRequest.java | 79 ++
.../common/protocol/em/RegisterEMRequest.java | 79 ++
.../em/RegisterEMResponse.java} | 34 +-
.../engine/EngineAskAsyncResponse.java} | 32 +-
.../protocol/engine/EngineAsyncResponse.java} | 11 +-
.../protocol/engine/EngineConnStatusCallback.java | 61 ++
.../engine/EngineConnStatusCallbackToAM.java | 71 ++
.../engine/EngineCreateError.java} | 45 +-
.../engine/EngineCreateSuccess.java} | 32 +-
.../protocol/engine/EngineOperateRequest.java} | 29 +-
.../protocol/engine/EngineOperateResponse.java} | 43 +-
.../label/LabelReportRequest.java} | 22 +-
.../label/LabelUpdateRequest.java} | 15 +-
.../protocol/resource/ResourceProtocol.java} | 6 +-
.../protocol/resource/ResourceUsedProtocol.java | 51 ++
.../protocol/resource/ResourceWithStatus.java | 103 +++
.../protocol/resource/ResponseTaskRunningInfo.java | 66 ++
.../resource/ResponseTaskYarnResource.java} | 25 +-
.../linkis/manager/common/utils/ManagerUtils.java | 4 +-
.../linkis/manager/common/utils/ResourceUtils.java | 312 ++++++++
.../linkis/manager/rm/AvailableResource.java} | 18 +-
.../linkis/manager/rm/NotEnoughResource.java} | 20 +-
.../RequestResourceAndWait.java} | 26 +-
.../node/LabelNode.java => rm/ResourceInfo.java} | 15 +-
.../apache/linkis/manager/rm/ResultResource.java} | 4 +-
.../manager/common/conf/ManagerCommonConf.scala | 34 -
.../manager/common/conf/RMConfiguration.scala | 91 ---
.../common/entity/recycle/RecyclingRule.scala | 32 -
.../manager/common/entity/resource/Resource.scala | 773 ------------------
.../linkis/manager/common/operator/Operator.scala | 44 -
.../manager/common/operator/OperatorFactory.scala | 64 --
.../manager/common/protocol/OperateRequest.scala | 45 --
.../common/protocol/em/ECMOperateRequest.scala | 37 -
.../protocol/em/EMResourceRegisterRequest.scala | 67 --
.../common/protocol/em/RegisterEMRequest.scala | 67 --
.../common/protocol/em/RegisterEMResponse.scala | 24 -
.../protocol/engine/EngineAsyncResponse.scala | 35 -
.../protocol/engine/EngineConnStatusCallback.scala | 55 --
.../protocol/engine/EngineOperateRequest.scala | 31 -
.../common/protocol/label/LabelUpdateRequest.scala | 27 -
.../protocol/resource/ResourceProtocol.scala | 48 --
.../protocol/resource/ResourceWithStatus.scala | 33 -
.../manager/common/utils/ResourceUtils.scala | 278 -------
.../linkis/manager/rm/ResourceManagerParam.scala | 51 --
.../apache/linkis/manager/rm/ResultResource.scala | 24 -
.../exception/PersistenceErrorException.java | 10 +-
.../persistence/NodeManagerPersistence.java | 20 +-
.../persistence/NodeMetricManagerPersistence.java | 10 +-
.../persistence/ResourceManagerPersistence.java | 6 +-
.../impl/DefaultNodeManagerPersistence.java | 29 +-
.../impl/DefaultNodeMetricManagerPersistence.java | 12 +-
.../impl/DefaultResourceLabelPersistence.java | 2 +-
.../impl/DefaultResourceManagerPersistence.java | 5 +-
.../flink/operator/TriggerSavepointOperator.java | 92 +++
.../flink/operator/TriggerSavepointOperator.scala | 49 --
.../spark/executor/SparkEngineConnExecutor.scala | 8 +-
...SparkSubmitProcessEngineConnLaunchBuilder.scala | 2 +-
.../service/ComputationTaskExecutionReceiver.scala | 10 +-
.../ecm/ComputationEngineConnManager.scala | 30 +-
.../ecm/cache/EngineAsyncResponseCache.scala | 16 +-
.../impl/ComputationEngineConnExecutor.scala | 2 +-
.../impl/DefaultEngineAsyncResponseService.scala | 12 +-
358 files changed, 16822 insertions(+), 14878 deletions(-)
create mode 100644
linkis-computation-governance/linkis-computation-governance-common/src/main/java/org/apache/linkis/governance/common/utils/ECPathUtils.java
delete mode 100644
linkis-computation-governance/linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/utils/ECPathUtils.scala
create mode 100644
linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnLogOperator.java
create mode 100644
linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/java/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.java
delete mode 100644
linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/operator/EngineConnLogOperator.scala
delete mode 100644
linkis-computation-governance/linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/operator/EngineConnYarnLogOperator.scala
create mode 100644
linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/java/org/apache/linkis/engineconn/once/executor/operator/OperableOnceEngineConnOperator.java
delete mode 100644
linkis-computation-governance/linkis-engineconn/linkis-clustered-engineconn/linkis-once-engineconn/src/main/scala/org/apache/linkis/engineconn/once/executor/operator/OperableOnceEngineConnOperator.scala
create mode 100644
linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/java/org/apache/linkis/engineconn/acessible/executor/operator/impl/EngineConnApplicationInfoOperator.java
delete mode 100644
linkis-computation-governance/linkis-engineconn/linkis-engineconn-executor/accessible-executor/src/main/scala/org/apache/linkis/engineconn/acessible/executor/operator/impl/EngineConnApplicationInfoOperator.scala
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderConf.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/conf/EngineConnPluginConfiguration.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/interceptor/EngineConnLaunchInterceptor.scala
=>
java/org/apache/linkis/engineplugin/server/interceptor/EngineConnLaunchInterceptor.java}
(76%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoader.scala
=>
java/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoaderFactory.java}
(63%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/AbstractEngineConnBmlResourceGenerator.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/DefaultEngineConnBmlResourceGenerator.java
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/locker/EngineNodeLocker.scala
=>
java/org/apache/linkis/engineplugin/server/localize/EngineConnBmlResourceGenerator.java}
(68%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
java/org/apache/linkis/engineplugin/server/localize/EngineConnLocalizeResource.java}
(77%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/localize/EngineConnLocalizeResourceImpl.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnLaunchService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceFactoryService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceService.java
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.scala
=>
java/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.java}
(73%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceFactoryService.scala
=>
java/org/apache/linkis/engineplugin/server/service/EngineConnResourceFactoryService.java}
(67%)
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/exception/RMErrorException.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnResourceRequest.java}
(51%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/EngineConnResourceService.java
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
java/org/apache/linkis/engineplugin/server/service/GetEngineConnResourceRequest.java}
(78%)
copy
linkis-computation-governance/{linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/exception/GovernanceErrorException.scala
=>
linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/engineplugin/server/service/RefreshAllEngineConnResourceRequest.java}
(69%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
java/org/apache/linkis/engineplugin/server/service/RefreshEngineConnResourceRequest.java}
(78%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/AMConfiguration.java
copy
linkis-computation-governance/linkis-manager/{linkis-manager-persistence/src/main/java/org/apache/linkis/manager/exception/PersistenceErrorException.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ApplicationManagerSpringConfiguration.java}
(64%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ConfigurationMapCache.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/DefaultEngineConnConfigurationService.java
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/node/LabelNode.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/EngineConnConfigurationService.java}
(81%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/conf/ManagerMonitorConf.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/converter/DefaultMetricsConverter.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/AMLabelChecker.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/AMLabelFilter.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/DefaultManagerLabelService.java
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=> java/org/apache/linkis/manager/am/label/EngineReuseLabelChooser.java} (78%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/label/MultiUserEngineReuseLabelChooser.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/locker/DefaultEngineNodeLocker.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/service/common/label/LabelFilter.scala
=> java/org/apache/linkis/manager/am/locker/EngineNodeLocker.java} (73%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEMNodeManager.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/DefaultEngineNodeManager.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/EMNodeManager.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/manager/EngineNodeManager.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/AbstractNodePointer.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultEMNodPointer.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultEngineNodPointer.java
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/ErrorException.java
=>
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/pointer/DefaultNodePointerBuilder.java
(52%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/recycle/RecyclingRuleExecutor.scala
=> java/org/apache/linkis/manager/am/recycle/AssignNodeRuleExecutor.java} (53%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/recycle/RecyclingRuleExecutor.scala
=> java/org/apache/linkis/manager/am/recycle/RecyclingRuleExecutor.java} (77%)
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/node/LabelNode.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/DefaultECAvailableRule.java}
(52%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/DefaultNodeSelector.java
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/node/LabelNode.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/ECAvailableRule.java}
(76%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/selector/NodeSelector.scala
=> java/org/apache/linkis/manager/am/selector/NodeSelector.java} (74%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/AvailableNodeSelectRule.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/selector/rule/ConcurrencyNodeSelectRule.scala
=>
java/org/apache/linkis/manager/am/selector/rule/ConcurrencyNodeSelectRule.java}
(52%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/selector/rule/HotspotExclusionRule.scala
=> java/org/apache/linkis/manager/am/selector/rule/HotspotExclusionRule.java}
(53%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/NewECMStandbyRule.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/selector/rule/NodeSelectRule.scala
=> java/org/apache/linkis/manager/am/selector/rule/NodeSelectRule.java} (81%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/ResourceNodeSelectRule.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/ScoreNodeSelectRule.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/selector/rule/TaskInfoNodeSelectRule.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/EMEngineService.scala
=> java/org/apache/linkis/manager/am/service/EMEngineService.java} (52%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/EngineService.scala
=> java/org/apache/linkis/manager/am/service/EngineService.java} (78%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/HeartbeatService.scala
=> java/org/apache/linkis/manager/am/service/HeartbeatService.java} (85%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/cache/ConfCacheRemoveBroadcastListener.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/DefaultEngineOperateService.scala
=> java/org/apache/linkis/manager/am/service/em/DefaultECMOperateService.java}
(53%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMEngineService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMInfoService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMRegisterService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/em/DefaultEMUnregisterService.java
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/{exception/AMErrorException.java
=> service/em/ECMOperateService.java} (68%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/em/EMInfoService.scala
=> java/org/apache/linkis/manager/am/service/em/EMInfoService.java} (66%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=> java/org/apache/linkis/manager/am/service/em/EMRegisterService.java} (69%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/{exception/AMErrorException.java
=> service/em/EMUnregisterService.java} (67%)
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/ErrorException.java
=>
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/AbstractEngineService.java
(56%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineAskEngineService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineConnCanKillService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineCreateService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineInfoService.java
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineOperateResponse.scala
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineOperateService.java}
(51%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineRecycleService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineReuseService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/DefaultEngineStopService.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/DefaultEngineSwitchService.scala
=>
java/org/apache/linkis/manager/am/service/engine/DefaultEngineSwitchService.java}
(68%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/EngineAskEngineService.scala
=>
java/org/apache/linkis/manager/am/service/engine/EngineAskEngineService.java}
(80%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
java/org/apache/linkis/manager/am/service/engine/EngineConnCanKillService.java}
(71%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
java/org/apache/linkis/manager/am/service/engine/EngineConnStatusCallbackService.java}
(73%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/EngineCreateService.scala
=> java/org/apache/linkis/manager/am/service/engine/EngineCreateService.java}
(67%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineInfoService.java
copy
linkis-computation-governance/{linkis-engineconn-manager/linkis-engineconn-manager-server/src/main/scala/org/apache/linkis/ecm/server/exception/ECMErrorException.scala
=>
linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineOperateService.java}
(65%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/EngineRecycleService.scala
=> java/org/apache/linkis/manager/am/service/engine/EngineRecycleService.java}
(72%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/EngineReuseService.scala
=> java/org/apache/linkis/manager/am/service/engine/EngineReuseService.java}
(69%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/engine/EngineStopService.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/engine/EngineSwitchService.scala
=> java/org/apache/linkis/manager/am/service/engine/EngineSwitchService.java}
(72%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/heartbeat/AMHeartbeatService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/service/monitor/NodeHeartbeatMonitor.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/util/LinkisUtils.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/utils/AMUtils.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/am/utils/DefaultRetryHandler.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/service/UserLabelService.scala
=> java/org/apache/linkis/manager/am/utils/RetryHandler.java} (59%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/LabelManagerUtils.scala
=> java/org/apache/linkis/manager/label/LabelManagerUtils.java} (61%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=> java/org/apache/linkis/manager/label/conf/LabelManagerConf.java} (75%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/score/DefaultNodeLabelScorer.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/score/LabelScoreServiceInstance.scala
=> java/org/apache/linkis/manager/label/score/LabelScoreServiceInstance.java}
(55%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/score/NodeLabelScorer.scala
=> java/org/apache/linkis/manager/label/score/NodeLabelScorer.java} (60%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/service/NodeLabelAddService.scala
=> java/org/apache/linkis/manager/label/service/NodeLabelAddService.java} (75%)
copy
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=> java/org/apache/linkis/manager/label/service/NodeLabelRemoveService.java}
(78%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/NodeLabelService.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/label/service/ResourceLabelService.scala
=> java/org/apache/linkis/manager/label/service/ResourceLabelService.java}
(62%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/service/common/label/ManagerLabelService.scala
=> java/org/apache/linkis/manager/label/service/UserLabelService.java} (62%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelAddService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelRemoveService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultResourceLabelService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/label/service/impl/DefaultUserLabelService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/entity/LabelResourceMapping.java
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/ServiceState.scala
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/entity/ResourceOperationType.java}
(85%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/external/yarn/YarnAppInfo.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/external/yarn/YarnResourceRequester.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/message/RMMessageService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/restful/RMMonitorRest.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/rm/service/LabelResourceService.scala
=> java/org/apache/linkis/manager/rm/service/LabelResourceService.java} (54%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/RequestResourceService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/ResourceLockService.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/rm/service/ResourceManager.scala
=> java/org/apache/linkis/manager/rm/service/ResourceManager.java} (68%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/localize/EngineConnBmlResourceGenerator.scala
=> java/org/apache/linkis/manager/rm/service/impl/ChangeType.java} (56%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/rm/service/impl/DefaultReqResourceService.scala
=>
java/org/apache/linkis/manager/rm/service/impl/DefaultReqResourceService.java}
(60%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/DriverAndYarnReqResourceService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/LabelResourceServiceImpl.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/ResourceLogService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/service/impl/UserResourceService.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/utils/RMUtils.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/rm/utils/UserConfiguration.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/service/em/EMUnregisterService.scala
=> java/org/apache/linkis/manager/service/common/label/LabelChecker.java} (70%)
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/node/LabelNode.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/label/LabelFilter.java}
(81%)
copy
linkis-computation-governance/linkis-manager/{linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/node/LabelNode.java
=>
linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/label/ManagerLabelService.java}
(75%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/java/org/apache/linkis/manager/service/common/metrics/MetricsConverter.java
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/service/common/pointer/EMNodPointer.scala
=> java/org/apache/linkis/manager/service/common/pointer/EMNodPointer.java}
(62%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/am/recycle/AssignNodeRuleExecutor.scala
=>
java/org/apache/linkis/manager/service/common/pointer/EngineNodePointer.java}
(55%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/manager/service/common/pointer/NodePointer.scala
=> java/org/apache/linkis/manager/service/common/pointer/NodePointer.java}
(62%)
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/{scala/org/apache/linkis/engineplugin/server/service/EngineConnLaunchService.scala
=>
java/org/apache/linkis/manager/service/common/pointer/NodePointerBuilder.java}
(71%)
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/loader/EngineConnPluginLoaderConf.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/conf/EngineConnPluginConfiguration.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/localize/AbstractEngineConnBmlResourceGenerator.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/localize/DefaultEngineConnBmlResourceGenerator.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnLaunchService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceFactoryService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/DefaultEngineConnResourceService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/service/EngineConnResourceService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/AMConfiguration.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/ConfigurationMapCache.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/EngineConnConfigurationService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/conf/ManagerMonitorConf.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/converter/DefaultMetricsConverter.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/AMLabelChecker.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/AMLabelFilter.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/DefaultManagerLabelService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/MultiUserEngineReuseLabelChooser.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/locker/DefaultEngineNodeLocker.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/DefaultEMNodeManager.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/DefaultEngineNodeManager.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/EMNodeManager.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/manager/EngineNodeManager.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/AbstractNodePointer.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultEMNodPointer.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultEngineNodPointer.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/DefaultNodeSelector.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/ECAvailableRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/AvailableNodeSelectRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/NewECMStandbyRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/OverLoadNodeSelectRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ResourceNodeSelectRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/ScoreNodeSelectRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/selector/rule/TaskInfoNodeSelectRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/cache/ConfCacheRemoveBroadcastListener.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultECMOperateService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMEngineService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMInfoService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMRegisterService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/DefaultEMUnregisterService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/ECMOperateService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/em/EMRegisterService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineAskEngineService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineConnCanKillService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineCreateService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineInfoService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineRecycleService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineReuseService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/DefaultEngineStopService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineConnCanKillService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineInfoService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineKillService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineOperateService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/EngineStopService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/heartbeat/AMHeartbeatService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/monitor/NodeHeartbeatMonitor.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/utils/AMUtils.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/conf/LabelManagerConf.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/score/DefaultNodeLabelScorer.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/NodeLabelRemoveService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/NodeLabelService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelAddService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelRemoveService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultNodeLabelService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultResourceLabelService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/label/service/impl/DefaultUserLabelService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/LabelResourceMap.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/external/yarn/YarnAppInfo.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/external/yarn/YarnResourceRequester.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/message/RMMessageService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/restful/RMMonitorRest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/RequestResourceService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/ResourceLockService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DefaultResourceManager.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/DriverAndYarnReqResourceService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/LabelResourceServiceImpl.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/ResourceLogService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/service/impl/UserResourceService.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/RMUtils.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/utils/UserConfiguration.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/metrics/MetricsConverter.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/EngineNodePointer.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/pointer/NodePointerBuilder.scala
rename
linkis-computation-governance/linkis-manager/linkis-application-manager/src/test/java/org/apache/linkis/manager/am/util/{ECResourceInfoUtilsTest.java
=> ECResourceInfoLinkisUtilsTest.java} (98%)
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/engineplugin/server/loader/EngineConnPluginsLoader.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/conf/ManagerCommonConf.java}
(55%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/conf/RMConfiguration.java
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/ErrorException.java
=>
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignEMNodeRule.java
(62%)
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/ErrorException.java
=>
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignNodeRule.java
(62%)
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/locker/EngineNodeLocker.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/recycle/AssignUserRule.java}
(75%)
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/ServiceHealthReport.scala
=> java/org/apache/linkis/manager/common/entity/recycle/RecyclingRule.java}
(81%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/CPUResource.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/DriverAndYarnResource.java
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/ErrorException.java
=>
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/InstanceResource.java
(52%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/LoadInstanceResource.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/LoadResource.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/MemoryResource.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/Resource.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/SpecialResource.java
copy
linkis-commons/linkis-common/src/main/java/org/apache/linkis/common/exception/LinkisRetryException.java
=>
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/UserAvailableResource.java
(66%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/entity/resource/YarnResource.java
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/monitor/ManagerMonitor.scala
=> java/org/apache/linkis/manager/common/monitor/ManagerMonitor.java} (88%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/Operator.java
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/service/common/label/LabelChecker.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/OperatorFactory.java}
(69%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/operator/OperatorFactoryImpl.java
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/ServiceState.scala
=> java/org/apache/linkis/manager/common/protocol/EngineLock.java} (82%)
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/pointer/DefaultNodePointerBuilder.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/OperateRequest.java}
(58%)
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/rm/entity/ResourceOperationType.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/OperateResponse.java}
(81%)
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/EngineLock.scala
=> java/org/apache/linkis/manager/common/protocol/RequestEngineLock.java} (56%)
copy
linkis-computation-governance/{linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/exception/GovernanceErrorException.scala
=>
linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/RequestEngineUnlock.java}
(70%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/RequestManagerUnlock.java
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/ResponseEngineLock.java} (52%)
copy
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/java/org/apache/linkis/manager/am/exception/AMErrorException.java
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/ResponseEngineUnlock.java}
(67%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/ECMOperateRequest.java
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/engine/EngineOperateResponse.scala
=> java/org/apache/linkis/manager/common/protocol/em/ECMOperateResponse.java}
(52%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/EMResourceRegisterRequest.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/em/RegisterEMRequest.java
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/em/RegisterEMResponse.java} (56%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/engine/EngineAskAsyncResponse.java} (54%)
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/OperateResponse.scala
=>
java/org/apache/linkis/manager/common/protocol/engine/EngineAsyncResponse.java}
(80%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallback.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallbackToAM.java
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/engine/EngineCreateError.java} (50%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/engine/EngineCreateSuccess.java} (57%)
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/service/engine/AbstractEngineService.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/engine/EngineOperateRequest.java}
(57%)
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/em/ECMOperateResponse.scala
=>
java/org/apache/linkis/manager/common/protocol/engine/EngineOperateResponse.java}
(52%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{entity/node/LabelNode.java
=> protocol/label/LabelReportRequest.java} (58%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{entity/node/LabelNode.java
=> protocol/label/LabelUpdateRequest.java} (71%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/ServiceState.scala
=>
java/org/apache/linkis/manager/common/protocol/resource/ResourceProtocol.java}
(81%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResourceUsedProtocol.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResourceWithStatus.java
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/protocol/resource/ResponseTaskRunningInfo.java
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/{exception/RMErrorException.java
=> protocol/resource/ResponseTaskYarnResource.java} (56%)
create mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/common/utils/ResourceUtils.java
rename
linkis-computation-governance/linkis-manager/{linkis-application-manager/src/main/scala/org/apache/linkis/manager/am/label/EngineReuseLabelRester.scala
=>
linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/AvailableResource.java}
(70%)
copy
linkis-computation-governance/{linkis-computation-governance-common/src/main/scala/org/apache/linkis/governance/common/exception/GovernanceErrorException.scala
=>
linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/rm/NotEnoughResource.java}
(70%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/{common/entity/node/LabelNode.java
=> rm/RequestResourceAndWait.java} (59%)
copy
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/java/org/apache/linkis/manager/{common/entity/node/LabelNode.java
=> rm/ResourceInfo.java} (71%)
rename
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/{scala/org/apache/linkis/manager/common/protocol/ServiceState.scala
=> java/org/apache/linkis/manager/rm/ResultResource.java} (91%)
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/conf/ManagerCommonConf.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/conf/RMConfiguration.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/entity/recycle/RecyclingRule.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/entity/resource/Resource.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/operator/Operator.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/operator/OperatorFactory.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/OperateRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/ECMOperateRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/EMResourceRegisterRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/RegisterEMRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/em/RegisterEMResponse.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineAsyncResponse.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineConnStatusCallback.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/engine/EngineOperateRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/label/LabelUpdateRequest.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceProtocol.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/protocol/resource/ResourceWithStatus.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/common/utils/ResourceUtils.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/rm/ResourceManagerParam.scala
delete mode 100644
linkis-computation-governance/linkis-manager/linkis-manager-common/src/main/scala/org/apache/linkis/manager/rm/ResultResource.scala
create mode 100644
linkis-engineconn-plugins/flink/src/main/java/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.java
delete mode 100644
linkis-engineconn-plugins/flink/src/main/scala/org/apache/linkis/engineconnplugin/flink/operator/TriggerSavepointOperator.scala
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
