raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

=clu #20613 logging selfRoles during node unreachable and quarantined (#20542)

Browse source
This commit is contained in:
Yegor Andreenko 2016-05-24 14:35:50 +02:00 • committed by Konrad Malawski
parent 72548d8439
commit c66e3a9f02
1 changed files with 5 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

10
akka-cluster/src/main/scala/akka/cluster/ClusterDaemon.scala
View file

@ -241,7 +241,7 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef) extends Actor with
import InternalClusterAction._ import InternalClusterAction._
val cluster = Cluster(context.system) val cluster = Cluster(context.system)
import cluster.{ selfAddress, scheduler, failureDetector } import cluster.{ selfAddress, selfRoles, scheduler, failureDetector }
import cluster.settings._ import cluster.settings._
import cluster.InfoLogger._ import cluster.InfoLogger._
@ -613,8 +613,8 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef) extends Actor with
val newOverview = localGossip.overview copy (reachability = newReachability) val newOverview = localGossip.overview copy (reachability = newReachability)
val newGossip = localGossip copy (overview = newOverview) val newGossip = localGossip copy (overview = newOverview)
updateLatestGossip(newGossip) updateLatestGossip(newGossip)
log.warning("Cluster Node [{}] - Marking node as TERMINATED [{}], due to quarantine", log.warning("Cluster Node [{}] - Marking node as TERMINATED [{}], due to quarantine. Node roles [{}]",
selfAddress, node.address) selfAddress, node.address, selfRoles.mkString(","))
publish(latestGossip) publish(latestGossip)
downing(node.address) downing(node.address)
} }
@ -1045,12 +1045,12 @@ private[cluster] class ClusterCoreDaemon(publisher: ActorRef) extends Actor with
val (exiting, nonExiting) = newlyDetectedUnreachableMembers.partition(_.status == Exiting) val (exiting, nonExiting) = newlyDetectedUnreachableMembers.partition(_.status == Exiting)
if (nonExiting.nonEmpty) if (nonExiting.nonEmpty)
log.warning("Cluster Node [{}] - Marking node(s) as UNREACHABLE [{}]", selfAddress, nonExiting.mkString(", ")) log.warning("Cluster Node [{}] - Marking node(s) as UNREACHABLE [{}]. Node roles [{}]", selfAddress, nonExiting.mkString(", "), selfRoles.mkString(", "))
if (exiting.nonEmpty) if (exiting.nonEmpty)
logInfo("Marking exiting node(s) as UNREACHABLE [{}]. This is expected and they will be removed.", logInfo("Marking exiting node(s) as UNREACHABLE [{}]. This is expected and they will be removed.",
exiting.mkString(", ")) exiting.mkString(", "))
if (newlyDetectedReachableMembers.nonEmpty) if (newlyDetectedReachableMembers.nonEmpty)
logInfo("Marking node(s) as REACHABLE [{}]", newlyDetectedReachableMembers.mkString(", ")) logInfo("Marking node(s) as REACHABLE [{}]. Node roles [{}]", newlyDetectedReachableMembers.mkString(", "), selfRoles.mkString(","))
publish(latestGossip) publish(latestGossip)
} }