diff --git a/akka-cluster-metrics/src/multi-jvm/scala/akka/cluster/metrics/ClusterMetricsRoutingSpec.scala b/akka-cluster-metrics/src/multi-jvm/scala/akka/cluster/metrics/ClusterMetricsRoutingSpec.scala index 731db6213d..12af43b20a 100644 --- a/akka-cluster-metrics/src/multi-jvm/scala/akka/cluster/metrics/ClusterMetricsRoutingSpec.scala +++ b/akka-cluster-metrics/src/multi-jvm/scala/akka/cluster/metrics/ClusterMetricsRoutingSpec.scala @@ -39,12 +39,12 @@ object AdaptiveLoadBalancingRouterConfig extends MultiNodeConfig { // getMax can be undefined (-1) val max = math.max(heap.getMax, heap.getCommitted) val used = heap.getUsed - log.debug("used heap before: [{}] bytes, of max [{}]", used, heap.getMax) + log.info("used heap before: [{}] bytes, of max [{}]", used, heap.getMax) // allocate 70% of free space val allocateBytes = (0.7 * (max - used)).toInt val numberOfArrays = allocateBytes / 1024 usedMemory = Array.ofDim(numberOfArrays, 248) // each 248 element Int array will use ~ 1 kB - log.debug("used heap after: [{}] bytes", ManagementFactory.getMemoryMXBean.getHeapMemoryUsage.getUsed) + log.info("used heap after: [{}] bytes", ManagementFactory.getMemoryMXBean.getHeapMemoryUsage.getUsed) sender() ! "done" } } @@ -73,6 +73,8 @@ object AdaptiveLoadBalancingRouterConfig extends MultiNodeConfig { # Enable metrics estension. akka.extensions=["akka.cluster.metrics.ClusterMetricsExtension"] + akka.failure-detector.acceptable-heartbeat-pause = 10s + # Use rapid metrics collection. akka.cluster.metrics { collector { diff --git a/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/AdaptiveLoadBalancingRouterSpec.scala b/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/AdaptiveLoadBalancingRouterSpec.scala index c13ef73aad..ccf4fb902b 100644 --- a/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/AdaptiveLoadBalancingRouterSpec.scala +++ b/akka-cluster/src/multi-jvm/scala/akka/cluster/routing/AdaptiveLoadBalancingRouterSpec.scala @@ -4,7 +4,7 @@ package akka.cluster.routing -// TODO remove metrics +// TODO remove metrics import language.postfixOps import java.lang.management.ManagementFactory @@ -40,12 +40,12 @@ object AdaptiveLoadBalancingRouterMultiJvmSpec extends MultiNodeConfig { // getMax can be undefined (-1) val max = math.max(heap.getMax, heap.getCommitted) val used = heap.getUsed - log.debug("used heap before: [{}] bytes, of max [{}]", used, heap.getMax) + log.info("used heap before: [{}] bytes, of max [{}]", used, heap.getMax) // allocate 70% of free space val allocateBytes = (0.7 * (max - used)).toInt val numberOfArrays = allocateBytes / 1024 usedMemory = Array.ofDim(numberOfArrays, 248) // each 248 element Int array will use ~ 1 kB - log.debug("used heap after: [{}] bytes", ManagementFactory.getMemoryMXBean.getHeapMemoryUsage.getUsed) + log.info("used heap after: [{}] bytes", ManagementFactory.getMemoryMXBean.getHeapMemoryUsage.getUsed) sender() ! "done" } } @@ -58,6 +58,7 @@ object AdaptiveLoadBalancingRouterMultiJvmSpec extends MultiNodeConfig { val third = role("third") commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString(""" + akka.failure-detector.acceptable-heartbeat-pause = 10s akka.cluster.metrics.collect-interval = 1s akka.cluster.metrics.gossip-interval = 1s akka.cluster.metrics.moving-average-half-life = 2s