dolphinscheduler的僵尸任务清理和清理一直在运行的任务状态 朱雀 2024-03-24 19:21 31阅读 0赞 dolphinscheduler的僵尸任务清理 ![在这里插入图片描述][69c3d21c4b18483bbae9c084d47dade7.png] 界面操作不了的 只能去数据库更改状态或则删除掉 原因:海豚调度中有几百条僵尸任务, 界面怎么也删不掉,想从数据库中删除,开始查找从数据库删除的办法。 参考以下脚本,结合我库中僵尸任务的特征,用end\_time is null删除了大半。 – 删除 任务实力中运行的任务 select \* from t\_ds\_process\_instance where end\_time is null and command\_type=9 实在找不到特征的,就按名字删除了。 – 删除 任务实力中运行的任务 select \* from t\_ds\_process\_instance where end\_time is null and command\_type=9 – state=6 end\_time is null \#删除工作流实例 select \* from t\_ds\_process\_instance where DATE\_FORMAT(start\_time ,“%Y-%m-%d”) = ‘2021-06-23’; delete from t\_ds\_process\_instance where DATE\_FORMAT(start\_time ,“%Y-%m-%d”) = ‘2021-06-23’ and state = ‘1’; \#删除工作流 select \* from t\_ds\_process\_definition where DATE\_FORMAT(create\_time ,“%Y-%m-%d”) = ‘2021-06-23’; delete from t\_ds\_process\_definition where DATE\_FORMAT(create\_time,“%Y-%m-%d”) = ‘2021-06-23’; \#删除任务和历史任务 select \* from dk\_hc\_task ; delete from dk\_hc\_task ; \#历史任务 select \* from dk\_hc\_history\_log ; delete from dk\_hc\_history\_log ; \#删除节点 select \* from dk\_hc\_workflow ; delete from dk\_hc\_workflow ; \#删除节点承载的目录 select \* from dk\_hc\_workflow\_folder ; delete from dk\_hc\_workflow\_folder where title !=‘根目录’; INSERT INTO dk\_hc\_workflow\_folder (id, title, wf\_id, create\_time, create\_user, update\_time, update\_user, parent\_id, type, expand, contextmenu, project\_id, edit\_user, flowType) VALUES(1, ‘根目录’, NULL, ‘2021-02-02 15:51:29.0’, 1, NULL, 1, 0, 1, 1, 1, 0, 1, NULL); \#删除临时表 select \* from t\_ds\_command ; delete from t\_ds\_command ; delete from t\_ds\_error\_command ; \#清除数据源 select \* from t\_ds\_datasource ; delete from t\_ds\_datasource where name != ‘192.168.111.222’ ; \#---------------------------------------工作空间管理---------------------------------------------------------- \#删除租户 select \* from t\_ds\_tenant where tenant\_code != ‘root’; delete from t\_ds\_tenant where tenant\_code != ‘root’; \#删除用户 select \* from t\_ds\_user where user\_name != ‘admin’; delete from t\_ds\_user where user\_name != ‘admin’; \#删除worker分组,default不在数据之内 select \* from t\_ds\_worker\_group ; delete from t\_ds\_worker\_group; \#删除警告邮件地址 select \* from t\_ds\_alertgroup ; delete from t\_ds\_alertgroup; \#删除令牌 select \* from t\_ds\_access\_token ; delete from t\_ds\_access\_token; \#删除队列 select \* from t\_ds\_queue where queue\_name !=‘default’; delete from t\_ds\_queue where queue\_name !=‘default’; \#删除项目空间 select \* from t\_ds\_project ; delete from t\_ds\_project where name !=‘临时调度’; \#---------------------------------------工作空间管理---------------------------------------------------------- \#清除datax的记录 select \* from dk\_datax\_statistics ; delete from dk\_datax\_statistics; [69c3d21c4b18483bbae9c084d47dade7.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/13/5cae8f46b1a3495bb47ad8618ff8f23d.png
还没有评论,来说两句吧...