[kafka] branch trunk updated: MINOR: Improve local variable name in UnifiedLog.maybeIncrementFirstUnstableOffset (#11253)

[junrao]

This is an automated email from the ASF dual-hosted git repository.

junrao pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git


The following commit(s) were added to refs/heads/trunk by this push:
     new 1d3b963  MINOR: Improve local variable name in 
UnifiedLog.maybeIncrementFirstUnstableOffset (#11253)
1d3b963 is described below

commit 1d3b96389b325520648d29b6363941f50e5b6d35
Author: Kowshik Prakasam <kpraka...@confluent.io>
AuthorDate: Thu Aug 26 13:27:51 2021 -0700

    MINOR: Improve local variable name in 
UnifiedLog.maybeIncrementFirstUnstableOffset (#11253)
    
    Reviewers: Jun Rao <jun...@gmail.com>
---
 core/src/main/scala/kafka/log/UnifiedLog.scala | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/core/src/main/scala/kafka/log/UnifiedLog.scala 
b/core/src/main/scala/kafka/log/UnifiedLog.scala
index 4f1024c..029d1fb 100644
--- a/core/src/main/scala/kafka/log/UnifiedLog.scala
+++ b/core/src/main/scala/kafka/log/UnifiedLog.scala
@@ -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
     }
   }