Storm 提交任務過程詳解 (不對地方麻煩指正)


1.使用的是Storm中自帶的一個測試jar包

 

提交下這任務到storm中去 

storm jar /usr/local/app/storm/examples/storm-starter/storm-starter-topologies-1.0.0.jar storm.starter.StatefulTopology T1

頁面看到的   ,很明顯提交任務成功了

看日志吧:

 

 主要日志就是我畫的那塊

1.

Uploading topology jar /usr/local/app/storm/examples/storm-starter/storm-starter-topologies-1.0.0.jar to assigned location: /usr/local/app/storm/storm-local/nimbus/inbox/stormjar-31cc7de5-fe1b-4822-b408-cdb0630f6d52.jar

這句日志  很明顯在說 ,上傳了一個topology jar 。放在了本地/usr/local/app/storm/storm-local/nimbus/inbox/下面 ,並且隨機生成了UUID 的名稱!

到底是不是有沒有?

 

Start uploading file '/usr/local/app/storm/examples/storm-starter/storm-starter-topologies-1.0.0.jar' to '/usr/local/app/storm/storm-local/nimbus/inbox/stormjar-31cc7de5-fe1b-4822-b408-cdb0630f6d52.jar' (55678503 bytes)
[==================================================] 55678503 / 55678503
File '/usr/local/app/storm/examples/storm-starter/storm-starter-topologies-1.0.0.jar' uploaded to '/usr/local/app/storm/storm-local/nimbus/inbox/stormjar-31cc7de5-fe1b-4822-b408-cdb0630f6d52.jar' (55678503 bytes)

 

這段日志其實還在說上傳並且開始上傳了,友好的提示上傳的進度 大小!等等

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM