You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@ignite.apache.org by "Pavel Pereslegin (JIRA)" <ji...@apache.org> on 2018/08/31 10:26:00 UTC
[jira] [Updated] (IGNITE-9442) Collocated IgniteSet#close is not working on non-affinity node.

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

Pavel Pereslegin updated IGNITE-9442:
-------------------------------------
    Description: 
Simple reproducer:

{code:java}
public void testSetBlockOnCloseFromNonAffinityNode() throws Exception {
        Ignite node = startGridsMultiThreaded(2);

        ClusterNode locNode = node.cluster().localNode();

         IgniteSet<Integer> set = node.set("test",
            new CollectionConfiguration().setCollocated(true).setNodeFilter(n -> !locNode.equals(n)));

        set.close();

        GridTestUtils.assertThrows(log, new Callable<Void>() {
            @Override public Void call() throws Exception {
                set.add(1);

                return null;
            }
        }, IllegalStateException.class, null);
    }
{code}

IgniteSet should be blocked on all nodes before cleanup data.

  was:
Simple reproducer:

{code:java}
public void testSetBlockOnCloseFromNonAffinityNode() throws Exception {
        Ignite node = startGridsMultiThreaded(2);

        ClusterNode locNode = node.cluster().localNode();

        IgniteSet<Integer> set = node.set("test",
            new CollectionConfiguration().setCollocated(true).setNodeFilter(n -> !F.eqNodes(locNode, n)));

        set.close();

        GridTestUtils.assertThrows(log, new Callable<Void>() {
            @Override public Void call() throws Exception {
                set.add(1);

                return null;
            }
        }, IllegalStateException.class, null);
    }
{code}

IgniteSet should be blocked on all nodes before cleanup data.


> Collocated IgniteSet#close is not working on non-affinity node.
> ---------------------------------------------------------------
>
>                 Key: IGNITE-9442
>                 URL: https://issues.apache.org/jira/browse/IGNITE-9442
>             Project: Ignite
>          Issue Type: Bug
>          Components: data structures
>    Affects Versions: 2.6
>            Reporter: Pavel Pereslegin
>            Assignee: Pavel Pereslegin
>            Priority: Major
>
> Simple reproducer:
> {code:java}
> public void testSetBlockOnCloseFromNonAffinityNode() throws Exception {
>         Ignite node = startGridsMultiThreaded(2);
>         ClusterNode locNode = node.cluster().localNode();
>          IgniteSet<Integer> set = node.set("test",
>             new CollectionConfiguration().setCollocated(true).setNodeFilter(n -> !locNode.equals(n)));
>         set.close();
>         GridTestUtils.assertThrows(log, new Callable<Void>() {
>             @Override public Void call() throws Exception {
>                 set.add(1);
>                 return null;
>             }
>         }, IllegalStateException.class, null);
>     }
> {code}
> IgniteSet should be blocked on all nodes before cleanup data.



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