dolphinscheduler的僵尸任务清理和清理一直在运行的任务状态

朱雀 2024-03-24 19:21 67阅读 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;