fix(s3stream/wal): fix check of scaleOutWindow

Signed-off-by: Ning Yu <ningyu@automq.com>
AutoMQ · Jan 2, 2024 · b5fcdef · b5fcdef
1 parent c5670e2
commit b5fcdef
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/s3stream/src/main/java/com/automq/stream/s3/wal/SlidingWindowService.java b/s3stream/src/main/java/com/automq/stream/s3/wal/SlidingWindowService.java
@@ -356,7 +356,7 @@ private void makeWriteOffsetMatchWindow(long newWindowEndOffset) throws IOExcept
             long newWindowMaxLength = newWindowEndOffset - windowStartOffset + scaleUnit;
             if (newWindowMaxLength > upperLimit) {
                 // exceed upper limit
-                if (newWindowEndOffset - windowStartOffset >= upperLimit) {
+                if (newWindowEndOffset - windowStartOffset <= upperLimit) {
                     // however, the new window length is still larger than upper limit, so we just set it to upper limit
                     newWindowMaxLength = upperLimit;
                 } else {