/**
* master server
*/
@componentscan(value = "org.apache.dolphinscheduler", excludefilters = {
@componentscan.filter(type = filtertype.regex, pattern = {
"org.apache.dolphinscheduler.server.worker.*",
"org.apache.dolphinscheduler.server.monitor.*",
"org.apache.dolphinscheduler.server.log.*"
})
})
@enabletransactionmanagement
public class masterserver implements istoppable {
/**
* master server startup, not use web service
*
* @param args arguments
*/
public static void main(string[] args) {
thread.currentthread().setname(constants.thread_name_master_server);
new springapplicationbuilder(masterserver.class).web(webapplicationtype.none).run(args);
}
/**
* run master server
*/
@postconstruct
public void run() {
// init remoting server
nettyserverconfig serverconfig = new nettyserverconfig();
serverconfig.setlistenport(masterconfig.getlistenport());
this.nettyremotingserver = new nettyremotingserver(serverconfig);
this.nettyremotingserver.registerprocessor(commandtype.task_execute_response, new taskresponseprocessor());
this.nettyremotingserver.registerprocessor(commandtype.task_execute_ack, new taskackprocessor());
this.nettyremotingserver.registerprocessor(commandtype.task_kill_response, new taskkillresponseprocessor());
this.nettyremotingserver.start();
// self tolerant
this.zkmasterclient.start();
this.zkmasterclient.setstoppable(this);
// scheduler start
this.masterschedulerservice.start();
// start quartzexecutors
// what system should do if exception
try {
logger.info("start quartz server...");
quartzexecutors.getinstance().start();
} catch (exception e) {
try {
quartzexecutors.getinstance().shutdown();
} catch (schedulerexception e1) {
logger.error("quartzexecutors shutdown failed : " e1.getmessage(), e1);
}
logger.error("start quartz failed", e);
}
/**
* register hooks, which are called before the process exits
*/
runtime.getruntime().addshutdownhook(new thread(() -> {
if (stopper.isrunning()) {
close("shutdownhook");
}
}));
}
代码来自dolphinscheduler版本1.3.6
相关推荐
dolphinscheduler-master-server-hadoop102
apache dolphinscheduler（apache-dolphinscheduler-2.0.5-src.tar.gz 源码）是一个分布式易扩展的可视化dag工作流任务调度开源系统。解决数据研发etl 错综复杂的依赖关系，不能直观监控任务健康状态等问题。dolphin...
dolphinscheduler分布式部署，有3个worker节点，3个master节点 操作：分别停止215、216、217运行的工作流实例 如图： 点击停止按钮 3. 现象：215、216机器上的任务一直运行中，217机器上的任务kill状态 如图 4. ...
grafana上dolphinscheduler-master使用的json文件
关于dolphinscheduler apache dolphinscheduler是一个分布式易扩展的可视化dag工作流任务调度开源系统。解决数据研发etl 错综复杂的依赖关系，不能直观监控任务健康状态等问题。dolphinscheduler以dag流式的方式将...
org.apache.dolphinscheduler.server.master.runner.task.commontaskprocessor:[125] - [workflowinstance-272][taskinstance-0] - submit task error。 该问题由版本bug解决，可以升级至dolphinscheduler2022年11月...
最新版的本地masterserver服务器。使用时可在awake里初始化： masterserver.ipaddress = "127.0.0.1"; masterserver.port = 23466;
source code raknet masterserver unity3d
apache dolphinscheduler(incubator,原easyscheduler）是一个大数据分布式工作流任务调度系统，主要解决大数据研发过程中etl处理错综复杂的依赖关系，而不能直观监控任务健康状态等问题。dolphinscheduler以dag流式...
fullcalendar-scheduler-master
nbu备份双击操作安装配置，如何搭建nbu服务端，配置策略，配置服务器，配置存储池，共享存储，nbu还是比较不错的一款数据库备份软件，支持sql，mysql，oracle等等
master server kit.rar
集成unity网络部分内容，实现服务器端与客户端连接，客户端创建对象，离线销毁对象，控制各自对象移动等，行行有注释，非常适合新手学习，欢迎下载。
light-task-scheduler-master.zip
kettle工具的web 自动调度工程，springmvc
很好用的一个服务器，一个主服务器，一个游戏服务区，还有区服务器
rhel 6.1 linux下安装与删除nbu7.1 master server.rar
游戏模拟器 66666666666666666666666666666666666666666666666
source code raknet proxyserver for unity3d
rtos 任务调度，msp430列子，可以参考。