diff --git a/hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java b/hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java index 756a48a3924bb..f1ebdcd449dec 100644 --- a/hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java +++ b/hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java @@ -57,7 +57,7 @@ public class BoundedInMemoryQueue implements Iterable { /** Rate used for sampling records to determine avg record size in bytes. **/ public static final int RECORD_SAMPLING_RATE = 64; - /** Maximum records that will be cached **/ + /** Maximum records that will be cached. **/ private static final int RECORD_CACHING_LIMIT = 128 * 1024; private static final Logger LOG = LogManager.getLogger(BoundedInMemoryQueue.class);