fix

pingcap · Sep 14, 2022 · a5a9053 · a5a9053
1 parent 87673bf
commit a5a9053
Showing 1 changed file with 8 additions and 7 deletions.
diff --git a/util/memory/tracker.go b/util/memory/tracker.go
@@ -412,13 +412,14 @@ func (t *Tracker) Consume(bs int64) {
 		}
 		// Update the Top1 session
 		memUsage := sessionTracker.BytesConsumed()
-		if limitSessMinSize := ServerMemoryLimitSessMinSize.Load(); limitSessMinSize > 0 && uint64(memUsage) < limitSessMinSize {
-			return
-		}
-		oldTracker := MemUsageTop1Tracker.Load()
-		for oldTracker.Compare(sessionTracker) {
-			if MemUsageTop1Tracker.CompareAndSwap(oldTracker, sessionTracker) {
-				break
+		if limitSessMinSize := ServerMemoryLimitSessMinSize.Load(); limitSessMinSize > 0 {
+			if uint64(memUsage) >= limitSessMinSize {
+				oldTracker := MemUsageTop1Tracker.Load()
+				for oldTracker.Compare(sessionTracker) {
+					if MemUsageTop1Tracker.CompareAndSwap(oldTracker, sessionTracker) {
+						break
+					}
+				}
 			}
 		}
 	}