This commit is contained in:
Clebert Suconic 2020-03-13 08:53:05 -04:00
commit 64d3cd54ee
1 changed files with 3 additions and 1 deletions

View File

@ -562,7 +562,9 @@ public class PageCursorProviderImpl implements PageCursorProvider {
synchronized (softCache) {
long pageId = (long) depagedPage.getPageId();
softCache.remove(pageId);
numberOfMessages.remove(pageId);
if (numberOfMessages != null) {
numberOfMessages.remove(pageId);
}
}
onDeletePage(depagedPage);
}