我已经启动了 Spark master 和 worker,并且可以轻松地在 HDFS 上运行 MapReduce,如 wordcount。
现在我想在 textstream 上运行一个流,当我想创建一个新的 StreamingContext 时,我遇到了这个错误:
scala> val ssc = new StreamingContext("spark://master:7077","test", Seconds(2))
13/07/17 11:13:45 INFO slf4j.Slf4jEventHandler: Slf4jEventHandler started
org.jboss.netty.channel.ChannelException: Failed to bind to: /192.168.2.105:48594
at org.jboss.netty.bootstrap.ServerBootstrap.bind(ServerBootstrap.java:298)
....
我检查了端口,Java 使用了它。我终止了这个过程,然后我退出了 Spark-shell。
有什么办法可以将 StreamingContext 的端口更改为随机的空闲端口?