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