diff --git a/src/main/java/org/springframework/data/couchbase/core/ReactiveFindByAnalyticsOperationSupport.java b/src/main/java/org/springframework/data/couchbase/core/ReactiveFindByAnalyticsOperationSupport.java index 53cce70de..a54639844 100644 --- a/src/main/java/org/springframework/data/couchbase/core/ReactiveFindByAnalyticsOperationSupport.java +++ b/src/main/java/org/springframework/data/couchbase/core/ReactiveFindByAnalyticsOperationSupport.java @@ -149,7 +149,8 @@ public Mono count() { } else { return throwable; } - }).flatMapMany(ReactiveAnalyticsResult::rowsAsObject).map(row -> row.getLong("__count")).next(); + }).flatMapMany(ReactiveAnalyticsResult::rowsAsObject) + .map(row -> row.getLong(row.getNames().iterator().next())).next(); }); }