diff --git a/src/main/java/com/commafeed/backend/dao/FeedEntryDAO.java b/src/main/java/com/commafeed/backend/dao/FeedEntryDAO.java index c2ae7867..a5a13790 100644 --- a/src/main/java/com/commafeed/backend/dao/FeedEntryDAO.java +++ b/src/main/java/com/commafeed/backend/dao/FeedEntryDAO.java @@ -36,7 +36,7 @@ public class FeedEntryDAO extends GenericDAO { } public List findFeedsExceedingCapacity(long maxCapacity, long max) { - NumberExpression count = entry.id.countDistinct(); + NumberExpression count = entry.id.count(); List tuples = newQuery().from(entry).groupBy(entry.feed).having(count.gt(maxCapacity)).limit(max).list(entry.feed.id, count); return tuples.stream().map(t -> new FeedCapacity(t.get(entry.feed.id), t.get(count))).collect(Collectors.toList()); }