借贵地问一个问题:我参考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
|