worker节点在apach strom中的执行

sc4hvdpw  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(340)

storm拓扑已在计算机x上使用storm命令部署。工作节点正在计算机y上运行。
一旦部署了拓扑,就可以处理元组了,工人正在处理请求和响应。
有谁能建议worker node如何识别工作和数据,因为我不确定worker node如何访问开发人员根本没有部署的代码?如果工作节点可以访问到拓扑的代码,您能否确定此代码的位置,并建议执行工作节点?

3b6akqbq

3b6akqbq1#

第一,你问了一个相当复杂的问题。我已经使用storm一段时间了,对它的内部工作原理不太了解。下面是一篇关于风暴的内部结构的好文章。它已经有两年多了,但仍然应该是高度相关的。我相信netty现在被用作内部消息传递,这在本文中被提到是实验性的。
对于在工作节点上运行的代码,storm.yaml中有一个配置,

storm.local.dir

上载拓扑时,我相信它会将jar复制到该位置。因此,每台不同的工作机都会在配置好的jar中有必要的jar storm.local.dir . 所以即使你只上传一台机器,storm也会把它分发给必要的工人(这是我的记忆,我现在还没来得及测试。)

相关问题