分享

spark运行错误

Wyy_Ck 发表于 2017-9-11 22:27:03 [显示全部楼层] 只看大图 回帖奖励 阅读模式 关闭右栏 1 5157
借贵地问一个问题:我参考spark官网实例 运行spark streaming实例


$ ./bin/run-example streaming.NetworkWordCount localhost 9999...-------------------------------------------Time: 1357008430000 ms-------------------------------------------
(hello,1)(world,1)...

$ nc -lk 9999
hello world

后台一直这样没有出现预想的结果,请问是什么原因呢?


17/09/07 16:20:36 INFO scheduler.JobScheduler: Added jobs for time 1504815636000 ms17/09/07 16:20:37 INFO scheduler.JobScheduler: Added jobs for time 1504815637000 ms17/09/07 16:20:38 INFO scheduler.JobScheduler: Added jobs for time 1504815638000 ms17/09/07 16:20:39 INFO scheduler.JobScheduler: Added jobs for time 1504815639000 ms17/09/07 16:20:40 INFO scheduler.JobScheduler: Added jobs for time 1504815640000 ms17/09/07 16:20:40 INFO memory.MemoryStore: Block input-0-1504815640600 stored as bytes in memory (estimated size 22.0 B, free 413.9 MB)17/09/07 16:20:40 INFO storage.BlockManagerInfo: Added input-0-1504815640600 in memory on 192.168.86.133:44473 (size: 22.0 B, free: 413.9 MB)17/09/07 16:20:40 INFO receiver.BlockGenerator: Pushed block input-0-150481564060017/09/07 16:20:41 INFO scheduler.JobScheduler: Added jobs for time 1504815641000 ms17/09/07 16:20:42 INFO scheduler.JobScheduler: Added jobs for time 1504815642000 ms QQ截图20170911222504.png




已有(1)人评论

跳转到指定楼层
yuwenge 发表于 2017-9-12 06:32:24
没看到出现错误呀、结果可能在下面。把全部截图发下
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条