2016-05-12 23 views
1

我是spark的初学者,我试图使用docker运行火花示例NetworkWordCount。但是,没有输出,当我运行示例:运行时无输出火花NetworkWordCount示例

开始通过docker exec -it container_id bash一个新的终端,

[email protected]:/usr/local/spark# nc -lk 9999 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 
a ba c d e f g 

再启动另一台终端:

[email protected]:/usr/local/spark# bin/run-example streaming.NetworkWordCount localhost 9999 
Using Spark's default log4j profile: org/apache/spark/log4j-defaults.properties 
16/05/12 02:55:57 INFO StreamingExamples: Setting log level to [WARN] for streaming example. To override add a custom log4j.properties to the classpath. 
16/05/12 02:55:58 WARN NativeCodeLoader: Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 
... 

任何人都可以帮我吗?

+0

你可以验证没有,你确实发送到本地主机9999? –

回答

0

执行使用下面的命令为我工作。

[[email protected] spark]# ./bin/run-example streaming.NetworkWordCount localhost 9999 --master "local[2]"