Nimbus(一) 清理目录
Nimbus(一) 清理目录

Nimbus启动的时候，其实是运行了一个thrift server，它会在topology提交之前，做一些清理一些东东.

什么东东？

1. 清理中断了的topology： 这个中断指的是在本地目录/STORM_LOCAL_DIR/stormdist下存在，而在ZK目录下/storms/topologyid下不存在的topology的信息。

stormdist下存的是topology的一些jar包、配置文件等。这里只清除ZK目录下的不需要的topology的信息，需要删除的ZK的相关目录是/STORM_DIR/tasks/topologyid,??/STORM_DIR/assignments/topologyid

2. nimbus还会间隔NIMBUS-MONITOR-FREQ-SECS时间清理不活跃的storm(storm的任务心跳和日志，删除stormdist下的topologyid目录)

3. nimbus?每间隔NIMBUS-CLEANUP-INBOX-FREQ-SECS长时间进行一次清理过期的jar包。

?

?

?

?

看代码