linkis1.0执行逻辑架构
2021-06-25 17:23:30 0 举报计算治理Linkis
作者其他创作
大纲/内容
DefaultManagerService
SparkEngineConnPlugin
ReadCacheConsumerManager
EngineTypeLabel
DefaultCodeExecTaskExecutorManager
执行Select 比如负载过高，返回没有负载低的EM，每个规则如果返回为空就抛出异常
ProcessEngineConnLaunch
QueryPersistenceEngine
NodeLabelScorer
UserLabelService
Policy
DefaultEngineConnPluginPointer
OnceExecutor
setupControllerServer
Persistence
Job/Stage/UserTask
entranceServer.execute
DefaultEngineConnManagerBuilder
ASTJob/Stage
createEngineResource
orchestrate
ServerSocket.onWebSocketText
EntranceExecutionJob
DefaultMarkReq
ServerListenerEventBus
label-common
DefaultEngineCreateService
LabelManager
DefaultEngineAskEngineService
ComputationExecutor
EMManager
ComputationEngineConnHook
SparkSubmitProcessEngineConnLaunchBuilder
updateEngineNode
createEngineConnLaunchRequest
LabelResourceService
linkis-engineconn-manager
EngineManager
DefaultEngineConnLaunchService
Planner
Reheater
JavaProcessEngineConnLaunchBuilder
requestResource
GuavaEngineConnPluginCache
NodeLabelService
EntranceParser
EntranceInterceptor
engineconn
DefaultEngineNodeManager
QueryPersistenceManager
DefaultECMHealthService
ASTJob
DefaultEntranceContext
Validator
DefaultUserLabelService
Parser
LinuxProcessEngineConnLaunchService
ExternalResourceService
User
LinuxProcessEngineConnLaunch
1.parseToTask/parseToOldTask2span style=\"font-size: inherit;\
OrchestratorSessionImpl
parseToTask
EngineReuseLabelChooser
LivelinessMonitor
getEngineNodes
FIFOUserConsumer
SparkScalaExecutor
Orchestrator
ComputationEngineConnManager
engineplugin
ResourceManager
persist
SparkEngineConnResourceFactory
EntranceGroupFactory
NodeLabelService getNodesByLabel 获取EMNodeList
EntranceExecutorManager
getOrCreateSession
OrchestratorSessionBuilderImpl
ExecutorManagerImpl
LabelEntities
Converter
ComputationEngineConnExecution
Job/Stage/UserExecTask
orchestration
EntranceSchedulerContext
DefaultEngineReuseService
DefaultEngineConnManager
UserResourceService
DefaultEngineConnPluginLoader
LinkisEntranceApplication
Optimizer
过滤Label
ParallelScheduler
LabelBuilder
OrchestrationImpl
DefaultNodeSelector
createOrchestratorSession
AbstractEntranceParser
实例化
ResourceLabelService
ParallelConsumerManager
AMHeartbeatService
EngineConnServer
CommonEntranceParser
DefaultEMEngineService
EngineResourceService
JobReq
OnceEngineConnExecution
addLabelsToNode
EMResourceService
Execution
DefaultEMNodeManager
LockManager
EntranceWebSocketService.onEvent
DefaultEntranceExecutor
EntranceResultSetEngine
DefaultEngineConnResourceService
执行Select 判断label分数、判断是否可用、判断负载获取Select后排在第一的engine，修改EngineNode的Label为新标签，并调用EngineNodeManager的reuse请求
ComputationOrchestratorSessionFactory
DefaultEngineConnResourceFactoryService
PostConstruct
BDPJettyServerHelper
MetadataManager
DefaultECMMetricsService
0 条评论
下一页
为你推荐
查看更多
