2013-11-20 29 views
1

我有一個Java Akka應用程序,現在已經添加了所需的配置,將它與Typesafe控制檯集成並監視系統。我的系統包含多個遠程節點,運行良好,但Typesafe控制檯不顯示/顯示任何內容。另一個空的Typesafe控制檯

我使用的common.conf如下:

akka { 
    actor { 
      provider = "akka.remote.RemoteActorRefProvider" 
    } 
    remote.netty.tcp.port = 0 
    remote.log-remote-lifecycle-events = off 
    loggers = ["akka.event.slf4j.Slf4jLogger", "com.typesafe.atmos.trace.Slf4jTraceContextLogger"] 
    loglevel = "INFO" 
    remote { 
      transport-failure-detector { 
        heartbeat-interval = 3 s 
        threshold = 10.0 
        max-sample-size = 100 
        min-std-deviation = 200 ms 
        acceptable-heartbeat-pause = 5 s 
      } 
      watch-failure-detector { 
        heartbeat-interval = 3 s 
        threshold = 12.0 
        max-sample-size = 200 
        min-std-deviation = 200 ms 
        acceptable-heartbeat-pause = 7 s 
        unreachable-nodes-reaper-interval = 3 s 
        expected-response-after = 6 s 
      } 
    } 
} 

atmos { 
    trace { 
      enabled = true 
      node = ${HOSTNAME} 
      traceable { 
        "*" = on 
      } 
      sampling { 
        "*" = 1 
      } 
    } 
} 

我覺得有點腥是ATMOS的配置不要求在類型安全控制檯運行時所在的任何引用。

我使用的application.conf如下:

MapReduceSystem { 
    include "common" 
    akka { 
      actor { 
        deployment { 
         /mapActor { 
          router = round-robin 
          nr-of-instances = ${MAPREDUCE_NUMBER_OF_JOBS} 
          target.nodes = ["akka.tcp://[email protected]:2552", "akka.tcp://[email protected]:2552", "akka.tcp://[email protected]:2552"] 
         } 
         /reduceActor { 
          remote = "akka.tcp://[email protected]:2552" 
          router = round-robin 
          nr-of-instances = 1 
         } 
         /masterActor { 
          remote = "akka.tcp://[email protected]:2552" 
          nr-of-instances = 1 
         } 
        } 
      } 
      remote.netty.tcp.port = 2552 
      remote.enabled-transports = ["akka.remote.netty.tcp"] 
      remote.netty.tcp.hostname = "olympus" 
    } 
} 

MapReduceNode { 
    include "common" 
    akka { 
      remote.netty.tcp.port = 2552 
      remote.enabled-transports = ["akka.remote.netty.tcp"] 
      remote.netty.tcp.hostname = ${HOSTNAME} 
    } 
} 

UPDATE:

ATMOS日誌顯示只有這個:

[email protected]:~/code/hpcmom/hpcmom-mapreduce$ sudo $TYPESAFE_CONSOLE_ROOT/bin/typesafe-console atmos 
2013-11-20 15:10:46,922 INFO [akka.event.slf4j.Slf4jEventHandler] [] [] : Slf4jEventHandler started 
2013-11-20 15:10:46,954 INFO [U] [ActorSystem(query)] [query-akka.actor.default-dispatcher-2] : *** No license available. Defaulting to in-memory persistence. *** 
2013-11-20 15:10:47,169 INFO [akka.event.slf4j.Slf4jEventHandler] [] [] : Slf4jEventHandler started 
2013-11-20 15:10:47,199 INFO [akka.event.slf4j.Slf4jEventHandler] [] [] : Slf4jEventHandler started 
2013-11-20 15:10:47,508 INFO [akka://query/user/IO-HTTP/listener-0] [akka://query/user/IO-HTTP/listener-0] [query-akka.actor.default-dispatcher-12] : Bound to olympus/192.168.92.21:8660 

回答

1

由於導入常見的配置在MapReduceSystem上下文Atmos將無法找到atmos配置部分。它預計在根級別的atmos配置。 嘗試將atmos部分直接添加到application.conf文件中。

+0

謝謝你的回答!我這樣做了,但沒有任何反應。我應該能夠看到正在運行的atmos或?查看更新。 –