No configuration setting found for key 'akka.zeromq'

[Francis . Hu]

hi,all

 

When i run ZeroMQWordCount example on cluster, the worker log says:   Caused
by: com.typesafe.config.ConfigException$Missing: No configuration setting
found for key 'akka.zeromq'

 

Actually, i can see that the reference.conf in
spark-examples-assembly-0.9.1.jar contains below configurations: 

Anyone know what happen ?

 

#####################################

# Akka ZeroMQ Reference Config File #

#####################################

 

# This is the reference config file that contains all the default settings.

# Make your edits/overrides in your application.conf.

 

akka {

 

  zeromq {

 

    # The default timeout for a poll on the actual zeromq socket.

    poll-timeout = 100ms

 

    # Timeout for creating a new socket

    new-socket-timeout = 5s

 

    socket-dispatcher {

      # A zeromq socket needs to be pinned to the thread that created it.

      # Changing this value results in weird errors and race conditions
within

      # zeromq

      executor = thread-pool-executor

      type = "PinnedDispatcher"

      thread-pool-executor.allow-core-timeout = off

    }

  }

}

 

------------------------Exception in worker------------------------

 

akka.actor.ActorInitializationException: exception during creation

        at akka.actor.ActorInitializationException$.apply(Actor.scala:218)

Caused by: com.typesafe.config.ConfigException$Missing: No configuration
setting found for key 'akka.zeromq'

14/05/06 21:26:19 ERROR actor.ActorCell: changing Recreate into Create after
akka.actor.ActorInitializationException: exception during creation

 

 

Thanks,

Francis.Hu