-
Notifications
You must be signed in to change notification settings - Fork 1.2k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[Scheduler Enhancement] Remove deleted containers. #5265
Conversation
@@ -593,7 +593,8 @@ object LoggingMarkers { | |||
val SCHEDULER_KAFKA = LogMarkerToken(scheduler, kafka, start)(MeasurementUnit.time.milliseconds) | |||
val SCHEDULER_KAFKA_WAIT_TIME = | |||
LogMarkerToken(scheduler, "kafkaWaitTime", counter)(MeasurementUnit.none) | |||
def SCHEDULER_WAIT_TIME(action: String) = LogMarkerToken(scheduler, "waitTime", counter, Some(action), Map("action" -> action))(MeasurementUnit.none) | |||
def SCHEDULER_WAIT_TIME(action: String) = | |||
LogMarkerToken(scheduler, "waitTime", counter, Some(action), Map("action" -> action))(MeasurementUnit.none) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Seems the content is same, just do format.
Normally, the time unit should be MeasurementUnit.time.milliseconds
, why here MeasurementUnit.none
?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I just kept the original one.
I would update it.
LGTM |
Codecov Report
@@ Coverage Diff @@
## master #5265 +/- ##
==========================================
- Coverage 80.27% 75.14% -5.14%
==========================================
Files 238 238
Lines 14066 14080 +14
Branches 574 576 +2
==========================================
- Hits 11292 10580 -712
- Misses 2774 3500 +726
Continue to review full report at Codecov.
|
* Apply ScalaFmt. * Do not send messages to deleted containers. * Use milliseconds as a measurement unit. * Fix test code.
Description
When some containers are terminated as they are idle, a memory queue still sends activations to them as their request are in the buffer.
Related issue and scope
My changes affect the following components
Types of changes
Checklist: