diff --git a/src/main/scala/mesosphere/marathon/core/launcher/impl/OfferProcessorImpl.scala b/src/main/scala/mesosphere/marathon/core/launcher/impl/OfferProcessorImpl.scala index 9335284c082..baaa33968b0 100644 --- a/src/main/scala/mesosphere/marathon/core/launcher/impl/OfferProcessorImpl.scala +++ b/src/main/scala/mesosphere/marathon/core/launcher/impl/OfferProcessorImpl.scala @@ -83,10 +83,11 @@ private[launcher] class OfferProcessorImpl( private def logOffer(offer: Offer): Unit = { val offerId = offer.getId.getValue val agentId = offer.getSlaveId.getValue - logger.debug(s"Processing offer: offerId $offerId, agentId $agentId") + logger.info(s"Processing offer: offerId $offerId, agentId $agentId (${offer.getHostname})") logger.debug(offer.toString) } + // This is likely beginning of offer matching override def processOffer(offer: Offer): Future[Done] = { incomingOffersMetric.increment() logOffer(offer) diff --git a/src/main/scala/mesosphere/marathon/core/launchqueue/impl/TaskLauncherActor.scala b/src/main/scala/mesosphere/marathon/core/launchqueue/impl/TaskLauncherActor.scala index 38f33bce621..feb08d2b4bc 100644 --- a/src/main/scala/mesosphere/marathon/core/launchqueue/impl/TaskLauncherActor.scala +++ b/src/main/scala/mesosphere/marathon/core/launchqueue/impl/TaskLauncherActor.scala @@ -346,7 +346,7 @@ private class TaskLauncherActor( private[this] def launchAllowed(now: Timestamp, configRef: RunSpecConfigRef): Boolean = launchAllowedAt.get(configRef).exists(_ <= now) private[this] def shouldLaunchInstances(now: Timestamp): Boolean = { if (scheduledInstances.nonEmpty || launchAllowedAt.nonEmpty) - logger.info(s"Found scheduled instances: ${scheduledInstances.map(_.instanceId).mkString(",")} and current back-off map: $launchAllowedAt") + logger.info(s"Found scheduled instances (current back-off map $launchAllowedAt): ${scheduledInstances.map(_.instanceId).mkString(",")}") scheduledInstances.nonEmpty && scheduledVersions.exists { configRef => launchAllowed(now, configRef) } }