Невозможно инициализировать контекст искры с помощью Java ⇐ JAVA

[Anonymous]

Я пробую простую программу подсчета работ с использованием spark, но при попытке инициализировать контекст искры она терпит неудачу.
Ниже приведен мой код

Код: Выделить всё

conf = new SparkConf(true).
setAppName("WordCount").
setMaster("spark://192.168.0.104:7077");

sc = new JavaSparkContext(conf);

Теперь несколько вещей, которые я хотел бы прояснить. Я использую Spark версии 2.1.1, мой Java-код находится в Windows 10, а мой сервер работает на виртуальной машине.
Я отключил брандмауэр в виртуальной машине и могу получить доступ к URL-адресу http://192.168.0.104:8080/ из Windows.

Однако при запуске кода я оказываюсь ниже трассировки стека< /p>

Код: Выделить всё

17/08/06 18:44:15 INFO SparkUI: Bound SparkUI to 0.0.0.0, and started at http://192.168.0.103:4040
17/08/06 18:44:15 INFO StandaloneAppClient$ClientEndpoint: Connecting to master spark://192.168.0.104:7077...
17/08/06 18:44:15 INFO TransportClientFactory: Successfully created connection to /192.168.0.104:7077 after 41 ms (0 ms spent in bootstraps)
17/08/06 18:44:15 WARN StandaloneAppClient$ClientEndpoint: Failed to connect to master 192.168.0.104:7077
org.apache.spark.SparkException: Exception thrown in awaitResult
at org.apache.spark.rpc.RpcTimeout$$anonfun$1.applyOrElse(RpcTimeout.scala:77)
at org.apache.spark.rpc.RpcTimeout$$anonfun$1.applyOrElse(RpcTimeout.scala:75)
at scala.runtime.AbstractPartialFunction.apply(AbstractPartialFunction.scala:33)
at org.apache.spark.rpc.RpcTimeout$$anonfun$addMessageIfTimeout$1.applyOrElse(RpcTimeout.scala:59)
at org.apache.spark.rpc.RpcTimeout$$anonfun$addMessageIfTimeout$1.applyOrElse(RpcTimeout.scala:59)

Может кто-нибудь помочь?

Подробнее здесь: https://stackoverflow.com/questions/455 ... using-java