Updated Branches: refs/heads/trunk 8dcabe83b -> 76a83d5a8
AMBARI-2812. Ambari server leaks memory. (swagle) Project: http://git-wip-us.apache.org/repos/asf/incubator-ambari/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ambari/commit/76a83d5a Tree: http://git-wip-us.apache.org/repos/asf/incubator-ambari/tree/76a83d5a Diff: http://git-wip-us.apache.org/repos/asf/incubator-ambari/diff/76a83d5a Branch: refs/heads/trunk Commit: 76a83d5a886e534bbbb709cbe04999e582aa31f3 Parents: 8dcabe8 Author: Siddharth Wagle <[email protected]> Authored: Tue Aug 6 12:18:45 2013 -0700 Committer: Siddharth Wagle <[email protected]> Committed: Tue Aug 6 12:18:45 2013 -0700 ---------------------------------------------------------------------- .../org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ambari/blob/76a83d5a/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java ---------------------------------------------------------------------- diff --git a/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java b/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java index 59a7a5f..12e3e41 100644 --- a/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java +++ b/ambari-server/src/main/java/org/apache/ambari/server/orm/dao/HostRoleCommandDAO.java @@ -44,7 +44,7 @@ public class HostRoleCommandDAO { DaoUtils daoUtils; private static Logger LOG = LoggerFactory.getLogger(HostRoleCommandDAO.class); private static final int REQUESTS_RESULT_LIMIT_WITH_FILTER = 20; - private static final int REQUESTS_RESULT_LIMIT = 200; + private static final int REQUESTS_RESULT_LIMIT = 100; @Transactional public HostRoleCommandEntity findByPK(long taskId) { @@ -66,6 +66,7 @@ public class HostRoleCommandDAO { "SELECT task FROM HostRoleCommandEntity task " + "WHERE task.requestId IN ?1 " + "ORDER BY task.taskId", HostRoleCommandEntity.class); + query.setMaxResults(REQUESTS_RESULT_LIMIT); return daoUtils.selectList(query, requestIds); } @@ -76,6 +77,7 @@ public class HostRoleCommandDAO { "WHERE task.requestId IN ?1 AND task.taskId IN ?2 " + "ORDER BY task.taskId", HostRoleCommandEntity.class ); + query.setMaxResults(REQUESTS_RESULT_LIMIT); return daoUtils.selectList(query, requestIds, taskIds); } @@ -183,6 +185,7 @@ public class HostRoleCommandDAO { queryStr.append("ORDER BY command.requestId DESC"); TypedQuery<Long> query = entityManagerProvider.get().createQuery(queryStr.toString(), Long.class); + query.setMaxResults(REQUESTS_RESULT_LIMIT); if (statuses != null && !statuses.isEmpty()) { results = daoUtils.selectList(query, statuses);
