This is an automated email from the ASF dual-hosted git repository.
manikumar 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 ee3b9c5 MINOR: Fix typos in LogValidator (#6449)
ee3b9c5 is described below
commit ee3b9c57fd4ba37aa34396da44ed04e55b224c18
Author: huxi <huxi...@hotmail.com>
AuthorDate: Fri Mar 15 14:54:42 2019 +0800
MINOR: Fix typos in LogValidator (#6449)
---
core/src/main/scala/kafka/log/LogValidator.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/scala/kafka/log/LogValidator.scala
b/core/src/main/scala/kafka/log/LogValidator.scala
index f7c7d04..8bf215e 100644
--- a/core/src/main/scala/kafka/log/LogValidator.scala
+++ b/core/src/main/scala/kafka/log/LogValidator.scala
@@ -341,7 +341,7 @@ private[kafka] object LogValidator extends Logging {
isTransactional: Boolean,
partitionLeaderEpoch: Int,
isFromClient: Boolean,
- uncompresssedSizeInBytes: Int):
ValidationAndOffsetAssignResult = {
+ uncompressedSizeInBytes: Int):
ValidationAndOffsetAssignResult = {
val startNanos = time.nanoseconds
val estimatedSize = AbstractRecords.estimateSizeInBytes(magic,
offsetCounter.value, compressionType,
validatedRecords.asJava)
@@ -362,7 +362,7 @@ private[kafka] object LogValidator extends Logging {
// message format V0 or if the inner offsets are not consecutive. This is
OK since the impact is the same: we have
// to rebuild the records (including recompression if enabled).
val conversionCount = builder.numRecords
- val recordConversionStats = new
RecordConversionStats(uncompresssedSizeInBytes +
builder.uncompressedBytesWritten,
+ val recordConversionStats = new
RecordConversionStats(uncompressedSizeInBytes +
builder.uncompressedBytesWritten,
conversionCount, time.nanoseconds - startNanos)
ValidationAndOffsetAssignResult(
