Storm 集群搭建和自定义调度器

编写项目并打包上传 为了方便, 这里我们把自定义调度器DirectScheduler和测试用拓扑程序DirectScheduledTopology放在一个项目中. pom.xml 自定义Scheduler 测试用拓扑 打成jar包, 上传至nimbus所在节点的storm下的lib目录下 集群环境搭建(3节点) 准备三台机器,hadoop001, hadoop002, hadoop003. 我们希望hadoop001启动: nimbus, ui, logviewer, supe... ... [查看更多]

Views: 307