準備工作:將開發好的jar包上傳到伺服器nimbus節點上,如package目錄下
啟動storm集群
storm jar ./wordcountbyandy.jar com.andy.learning.storm_helloworld.******topology testtask1
解釋下這條命令中的各個引數:
執行結果如圖所示
提交拓撲任務
稍等下就會顯示拓撲任務提交成功。
拓撲任務列表
監控ui
在這裡我們可以看到當前有1條任務,並且執行在storm2的supervisor上。
tail
-fworker
.log
我們可以看到,終端中已經出現了不斷變化的詞頻統計
到此為止,我們的wordcount任務提交完成,提交了乙個最基本的拓撲任務。
停止任務的兩種方式,1是通過命令列,2是通過控制台管理任務。ElasticSearch之二 集群
首先看下elasticsearch es 的架構 術語解釋 es的分布式操作大多是自動完成的 1 跨節點平衡集群中各節點的索引與搜尋負載 2 自動複製索引資料以提供冗餘副本,防止硬體錯誤導致資料丟失 3 自動在節點之間路由,以幫助找到檢索的資料 4 無縫擴充套件或者恢復集群 node 節點 是es執...
elasticsearch技術總結(二) 集群管理
所謂集群管理是指集群搭建好後的日常維護和管理。一 集群健康 集群狀態分為三種 green 所有主分片以及副分片都可用 yellow 部分副本不可用 red 丟失分片 其中集群狀態為 green 和 yellow 集群正常,資料完整 狀態為red部分資料丟失,分配到缺失分片的操作會有異常 集群狀態以及...
zookeeper安裝二 集群安裝
1.centos7.6最小化安裝 2.jdk1.8 3.zookeeper 3.4.14 區別 分別是192.168.255.130,192.168.255.131,192.168.255.132 server.1 192.168.255.130 2888 3888 server.2 192.168...