Polish the cleanExpiredEvents

apache · Aug 23, 2024 · 106c4b3 · 106c4b3
1 parent f5ea00e
commit 106c4b3
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java b/...jdbc/src/main/java/org/apache/flink/autoscaler/jdbc/event/JdbcAutoScalerEventHandler.java
@@ -165,9 +165,9 @@ void cleanExpiredEvents() {
                 }
 
                 for (long startId = minId;
-                        batchSize
-                                == jdbcEventInteractor.deleteExpiredEventsByIdRangeAndDate(
-                                        startId, startId + batchSize, date);
+                        jdbcEventInteractor.deleteExpiredEventsByIdRangeAndDate(
+                                        startId, startId + batchSize, date)
+                                == batchSize;
                         startId += batchSize) {
                     Thread.sleep(sleepMs);
                 }