MINOR: Fix the negative time difference value from Log
Reviewers: Lucas Bradstreet Chia-Ping Tsai David Jacot
@@ -1017,7 +1017,7 @@ class Log(@volatile private var _dir: File,
}
producerStateManager.updateMapEndOffset(lastOffset)
producerStateManager.takeSnapshot()
- info(s"Producer state recovery took ${producerStateLoadStart - segmentRecoveryStart}ms for snapshot load " +
+ info(s"Producer state recovery took ${segmentRecoveryStart - producerStateLoadStart}ms for snapshot load " +
s"and ${time.milliseconds() - segmentRecoveryStart}ms for segment recovery from offset $lastOffset")
}
}
