MINOR: Improve local variable name in UnifiedLog.maybeIncrementFirstUnstableOffset
Reviewers: Jun Rao
@@ -959,16 +959,16 @@ class UnifiedLog(@volatile var logStartOffset: Long,
private def maybeIncrementFirstUnstableOffset(): Unit = lock synchronized {
localLog.checkIfMemoryMappedBufferClosed()
- val updatedFirstStableOffset = producerStateManager.firstUnstableOffset match {
+ val updatedFirstUnstableOffset = producerStateManager.firstUnstableOffset match {
case Some(logOffsetMetadata) if logOffsetMetadata.messageOffsetOnly || logOffsetMetadata.messageOffset < logStartOffset =>
val offset = math.max(logOffsetMetadata.messageOffset, logStartOffset)
Some(convertToOffsetMetadataOrThrow(offset))
case other => other
}
- if (updatedFirstStableOffset != this.firstUnstableOffsetMetadata) {
- debug(s"First unstable offset updated to $updatedFirstStableOffset")
- this.firstUnstableOffsetMetadata = updatedFirstStableOffset
+ if (updatedFirstUnstableOffset != this.firstUnstableOffsetMetadata) {
+ debug(s"First unstable offset updated to $updatedFirstUnstableOffset")
+ this.firstUnstableOffsetMetadata = updatedFirstUnstableOffset
}
}
