Storm示例即使没有zookeeper, nimbus和supervisor进程也能运行



我已经按照给出的说明在1台机器上设置了一个storm节点

我按照说明启动了zookeeper, nimbus和supervisor进程。然后我在这里和这里找到storm示例,编译它们(使用maven)并运行jar文件。他们都跑得很好。

然后我停止了supervisor, nimbus和zookeeper进程(按此顺序),并编译并再次运行示例。

令我惊讶的是,它们仍然编译和运行,好像什么都没有改变。为了绝对确定进程已被杀死,我关闭了计算机并重新启动了它。这一次,我编译并运行了示例,甚至没有启动zookeeper、nimbus或supervisor进程。

为什么会发生这种情况,我错过了什么?

如果我错过了什么明显的,请原谅我。我是Storm和分布式系统的新手。

Zookeepers在Storm中的作用是在多节点Storm集群中提供服务发现和协调,对于单节点Storm节点它没有任何作用

发现了我的错误。我使用LocalCluster提交拓扑,而不是StormSubmitter

最新更新