[jira] [Updated] (IGNITE-12778) KILL QUERY command doesn't close already fetched cursor

[Nikolay Izhikov (Jira)]

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

Nikolay Izhikov updated IGNITE-12778:
-------------------------------------
    Description: 
KILL QUERY doesn't close already fetched cursor.
Reproducer:

{code:java}
    public void testCancelSQLQuery() throws Exception {
        startGrids(NODES_CNT);
        IgniteEx client = startClientGrid("client");

        client.cluster().state(ACTIVE);

        IgniteCache<Object, Object> cache = client.getOrCreateCache(
            new 
CacheConfiguration<>(DEFAULT_CACHE_NAME).setIndexedTypes(Integer.class, 
Integer.class));

        for (int i = 0; i < PAGE_SZ * PAGE_SZ; i++)
            cache.put(i, i);

        SqlFieldsQuery qry = new SqlFieldsQuery("SELECT _KEY, _VAL FROM 
INTEGER").setSchema("default").setPageSize(10);
        Iterator<List<?>> iter = queryProcessor(client).querySqlFields(qry, 
true).iterator();

        assertNotNull(iter.next());

        List<List<?>> sqlQries = SqlViewExporterSpiTest.execute(client,
            "SELECT * FROM SYS.SQL_QUERIES ORDER BY START_TIME");
        assertEquals(2, sqlQries.size());

        String qryId = (String)sqlQries.get(0).get(0);
        assertEquals("SELECT _KEY, _VAL FROM INTEGER", sqlQries.get(0).get(1));

        SqlViewExporterSpiTest.execute(client, "KILL QUERY '" + qryId + "'");

        while(iter.hasNext())
            assertNotNull(iter.next());

        fail("You shouldn't be here!"); //Fails here for now. but should fails 
on iter.next call.

{code}

  was:
KILL QUERY doesn't close already fetched cursor.
Reproducer:

{code:java}
    public void testCancelSQLQuery() throws Exception {
        startGrids(NODES_CNT);
        IgniteEx client = startClientGrid("client");

        client.cluster().state(ACTIVE);

        IgniteCache<Object, Object> cache = client.getOrCreateCache(
            new 
CacheConfiguration<>(DEFAULT_CACHE_NAME).setIndexedTypes(Integer.class, 
Integer.class));

        for (int i = 0; i < PAGE_SZ * PAGE_SZ; i++)
            cache.put(i, i);

        SqlFieldsQuery qry = new SqlFieldsQuery("SELECT _KEY, _VAL FROM 
INTEGER").setSchema("default").setPageSize(10);
        Iterator<List<?>> iter = queryProcessor(client).querySqlFields(qry, 
true).iterator();

        assertNotNull(iter.next());

        List<List<?>> sqlQries = SqlViewExporterSpiTest.execute(client,
            "SELECT * FROM SYS.SQL_QUERIES ORDER BY START_TIME");
        assertEquals(2, sqlQries.size());

        String qryId = (String)sqlQries.get(0).get(0);
        assertEquals("SELECT _KEY, _VAL FROM INTEGER", sqlQries.get(0).get(1));

        QueryMXBean qryMBean = getMxBean(client.name(), "Query",
            QueryMXBeanImpl.class.getSimpleName(), QueryMXBean.class);

        qryMBean.cancelSQL(qryId);

        //SqlViewExporterSpiTest.execute(client, "KILL QUERY '" + qryId + "'");

        while(iter.hasNext())
            assertNotNull(iter.next());

        fail("You shouldn't be here!"); //Fails here for now. but should fails 
on iter.next call.

{code}


> KILL QUERY command doesn't close already fetched cursor
> -------------------------------------------------------
>
>                 Key: IGNITE-12778
>                 URL: https://issues.apache.org/jira/browse/IGNITE-12778
>             Project: Ignite
>          Issue Type: Bug
>          Components: sql
>    Affects Versions: 2.8
>            Reporter: Nikolay Izhikov
>            Assignee: Nikolay Izhikov
>            Priority: Major
>             Fix For: 2.9
>
>
> KILL QUERY doesn't close already fetched cursor.
> Reproducer:
> {code:java}
>     public void testCancelSQLQuery() throws Exception {
>         startGrids(NODES_CNT);
>         IgniteEx client = startClientGrid("client");
>         client.cluster().state(ACTIVE);
>         IgniteCache<Object, Object> cache = client.getOrCreateCache(
>             new 
> CacheConfiguration<>(DEFAULT_CACHE_NAME).setIndexedTypes(Integer.class, 
> Integer.class));
>         for (int i = 0; i < PAGE_SZ * PAGE_SZ; i++)
>             cache.put(i, i);
>         SqlFieldsQuery qry = new SqlFieldsQuery("SELECT _KEY, _VAL FROM 
> INTEGER").setSchema("default").setPageSize(10);
>         Iterator<List<?>> iter = queryProcessor(client).querySqlFields(qry, 
> true).iterator();
>         assertNotNull(iter.next());
>         List<List<?>> sqlQries = SqlViewExporterSpiTest.execute(client,
>             "SELECT * FROM SYS.SQL_QUERIES ORDER BY START_TIME");
>         assertEquals(2, sqlQries.size());
>         String qryId = (String)sqlQries.get(0).get(0);
>         assertEquals("SELECT _KEY, _VAL FROM INTEGER", 
> sqlQries.get(0).get(1));
>         SqlViewExporterSpiTest.execute(client, "KILL QUERY '" + qryId + "'");
>         while(iter.hasNext())
>             assertNotNull(iter.next());
>         fail("You shouldn't be here!"); //Fails here for now. but should 
> fails on iter.next call.
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)