@@ -79,22 +79,22 @@ class MesosJobFramework @Inject()(
79
79
// entire task stream.
80
80
@ Override
81
81
def resourceOffers (schedulerDriver : SchedulerDriver , receivedOffers : java.util.List [Offer ]) {
82
- log.info (" Received resource offers" )
82
+ log.fine (" Received resource offers" )
83
83
import scala .collection .JavaConverters ._
84
84
85
85
val offers = receivedOffers.asScala.toList
86
86
val offerResources = mutable.HashMap (offers.map(o => (o, Resources (o))).toSeq: _* )
87
87
val tasksToLaunch = generateLaunchableTasks(offerResources)
88
88
89
- log.info (" Declining unused offers." )
89
+ log.fine (" Declining unused offers." )
90
90
val usedOffers = mutable.HashSet (tasksToLaunch.map(_._3.getId.getValue): _* )
91
91
92
92
offers.foreach(o => {
93
93
if (! usedOffers.contains(o.getId.getValue))
94
94
mesosDriver.get().declineOffer(o.getId, declineOfferFilters)
95
95
})
96
96
97
- log.info (s " Declined unused offers with filter refuseSeconds= ${declineOfferFilters.getRefuseSeconds} " +
97
+ log.fine (s " Declined unused offers with filter refuseSeconds= ${declineOfferFilters.getRefuseSeconds} " +
98
98
s " (use -- ${config.declineOfferDuration.name} to reconfigure) " )
99
99
100
100
launchTasks(tasksToLaunch)
@@ -119,7 +119,7 @@ class MesosJobFramework @Inject()(
119
119
@ tailrec
120
120
def generate () {
121
121
taskManager.getTask match {
122
- case None => log.info (" No tasks scheduled or next task has been disabled.\n " )
122
+ case None => log.fine (" No tasks scheduled or next task has been disabled.\n " )
123
123
case Some ((taskId, job)) =>
124
124
if (runningTasks.contains(job.name)) {
125
125
val deleted = taskManager.removeTask(taskId)
0 commit comments