Nimbus(一) 清理目录

Nimbus(一) 清理目录 Nimbus启动的时候,其实是运行了一个thrift server,它会在topology提交之前,做一些清理一些东东. 什么东东? 1. 清理中断了的topology: 这个中断指的是在本地目录/STORM_LOCAL_DIR/stormdist下存在,而在ZK目录下/storms/topologyid下不存在的topology的信息。 stormdist下存的是t
相关文章
相关标签/搜索