[jira] [Assigned] (IGNITE-9196) SQL: Memory leak in MapNodeResults

["Denis Mekhanikov (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/IGNITE-9196?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Denis Mekhanikov reassigned IGNITE-9196:
----------------------------------------

    Assignee: Denis Mekhanikov

> SQL: Memory leak in MapNodeResults
> ----------------------------------
>
>                 Key: IGNITE-9196
>                 URL: https://issues.apache.org/jira/browse/IGNITE-9196
>             Project: Ignite
>          Issue Type: Bug
>          Components: sql
>    Affects Versions: 2.6
>            Reporter: Denis Mekhanikov
>            Assignee: Denis Mekhanikov
>            Priority: Blocker
>
> When size of a SQL query result set is a multiple of {{Query#pageSize}}, then {{MapQueryResult}} is never closed and removed from {{MapNodeResults#res}} collection.
> The following code leads to OOME when run with 1Gb heap:
> {code:java}
> public class MemLeakRepro {
>     public static void main(String[] args) {
>         Ignition.start(getConfiguration("server"));
>         try (Ignite client = Ignition.start(getConfiguration("client").setClientMode(true))) {
>             IgniteCache<Integer, Person> cache = startPeopleCache(client);
>             int pages = 10;
>             int pageSize = 1024;
>             for (int i = 0; i < pages * pageSize; i++) {
>                 Person p = new Person("Person #" + i, 25);
>                 cache.put(i, p);
>             }
>             for (int i = 0; i < 1_000_000; i++) {
>                 if (i % 1000 == 0)
>                     System.out.println("Select iteration #" + i);
>                 Query<List<?>> qry = new SqlFieldsQuery("select * from people");
>                 qry.setPageSize(pageSize);
>                 QueryCursor<List<?>> cursor = cache.query(qry);
>                 cursor.getAll();
>                 cursor.close();
>             }
>         }
>     }
>     private static IgniteConfiguration getConfiguration(String instanceName) {
>         IgniteConfiguration igniteCfg = new IgniteConfiguration();
>         igniteCfg.setIgniteInstanceName(instanceName);
>         TcpDiscoverySpi discoSpi = new TcpDiscoverySpi();
>         discoSpi.setIpFinder(new TcpDiscoveryVmIpFinder(true));
>         return igniteCfg;
>     }
>     private static IgniteCache<Integer, Person> startPeopleCache(Ignite node) {
>         CacheConfiguration<Integer, Person> cacheCfg = new CacheConfiguration<>("cache");
>         QueryEntity qe = new QueryEntity(Integer.class, Person.class);
>         qe.setTableName("people");
>         cacheCfg.setQueryEntities(Collections.singleton(qe));
>         cacheCfg.setSqlSchema("PUBLIC");
>         return node.getOrCreateCache(cacheCfg);
>     }
>     public static class Person {
>         @QuerySqlField
>         private String name;
>         @QuerySqlField
>         private int age;
>         public Person(String name, int age) {
>             this.name = name;
>             this.age = age;
>         }
>     }
> }
> {code}
>  
> At the same time it works perfectly fine, when there are, for example, {{pages * pageSize - 1}} records in cache instead.
> The reason for it is that {{MapQueryResult#fetchNextPage(...)}} method doesn't return true, when the result set size is a multiple of the page size.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)