SONAR-11881 ORA-01795 failure in CeQueueDao

diff --git a/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueDao.java b/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueDao.java
index 91635a974c7b5eb3b3ad58b16afb4716e5b9a2eb..127161d8a3d8a2a6f53a5914d1245920eb07ce49 100644 (file)
--- a/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueDao.java
+++ b/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueDao.java
@@ -156,8 +156,8 @@ public class CeQueueDao implements Dao {
     ImmutableMap.Builder<String, Integer> builder = ImmutableMap.builder();
     executeLargeUpdates(
       projectUuids,
-      uuids -> {
-        List<QueueCount> i = mapper(dbSession).countByStatusAndMainComponentUuids(status, projectUuids);
+      partitionOfProjectUuids -> {
+        List<QueueCount> i = mapper(dbSession).countByStatusAndMainComponentUuids(status, partitionOfProjectUuids);
         i.forEach(o -> builder.put(o.getMainComponentUuid(), o.getTotal()));
       });
     return builder.build();

diff --git a/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueMapper.java b/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueMapper.java
index 46176901d1bec2381ed477ce3573e30fabb41081..a8c3647547c7ae2039f799f96c0779e7b9cc4fd7 100644 (file)
--- a/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueMapper.java
+++ b/server/sonar-db-dao/src/main/java/org/sonar/db/ce/CeQueueMapper.java
@@ -20,7 +20,6 @@
 package org.sonar.db.ce;
 
 import java.util.List;
-import java.util.Set;
 import javax.annotation.CheckForNull;
 import javax.annotation.Nullable;
 import org.apache.ibatis.annotations.Param;
@@ -69,7 +68,7 @@ public interface CeQueueMapper {
 
   int countByStatusAndMainComponentUuid(@Param("status") CeQueueDto.Status status, @Nullable @Param("mainComponentUuid") String mainComponentUuid);
 
-  List<QueueCount> countByStatusAndMainComponentUuids(@Param("status") CeQueueDto.Status status, @Param("mainComponentUuids") Set<String> mainComponentUuids);
+  List<QueueCount> countByStatusAndMainComponentUuids(@Param("status") CeQueueDto.Status status, @Param("mainComponentUuids") List<String> mainComponentUuids);
 
   void insert(CeQueueDto dto);