fix sort memory (#260)

boomerang-io · Jan 17, 2023 · 8a4c6e2 · 8a4c6e2
1 parent fc57e7a
commit 8a4c6e2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/main/java/io/boomerang/mongo/repository/FlowWorkflowVersionRepository.java b/src/main/java/io/boomerang/mongo/repository/FlowWorkflowVersionRepository.java
@@ -5,6 +5,7 @@
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.mongodb.repository.Aggregation;
+import org.springframework.data.mongodb.repository.Meta;
 import org.springframework.data.mongodb.repository.MongoRepository;
 import io.boomerang.mongo.entity.RevisionEntity;
 import io.boomerang.mongo.model.WorkFlowRevisionCount;
@@ -29,13 +30,15 @@ RevisionEntity findByworkFlowIdAndVersionAndDagTasksTaskIdAndDagTasksPropertiesK
 	      "{'$sort':{'workFlowId': -1, version: -1}}",
 	      "{'$group': { _id: '$workFlowId', 'count': { $sum: 1 }}}"
 	})
+  @Meta(allowDiskUse = true)
   List<WorkFlowRevisionCount> findWorkFlowVersionCounts(List<String> workflowIds);
 
   @Aggregation(pipeline = {
 		  "{'$match':{'workFlowId': {$in: ?0}}}",
 	      "{'$sort':{'workFlowId': -1, version: -1}}",
 	      "{'$group': { _id: '$workFlowId', 'count': { $sum: 1 }, 'latestVersion': {$first: '$$ROOT'}}}"
 	})
+  @Meta(allowDiskUse = true)
   List<WorkFlowRevisionCount> findWorkFlowVersionCountsAndLatestVersion(List<String> workflowIds);
 
 }