[infinispan-dev] failing queries on one node

[Sanne Grinovero]

Team, I hope someone more familiar with state transfer and cache
starting logic can help Ales as I don't think this is a Query or
Hibernate Search related problem.
Even more as his test was working not so long ago, and there where no
Search releases nor mayor changes in Infinispan Query.

This problem and the locking errors he reported in a different post
are very likely related: if the background thread in Hibernate
Search's backend fails to update the index because of the locking
issue, it doesn't surprise me that the other nodes are unable to see
an updated index (as write operations failed).

Cheers,
Sanne

On 3 September 2012 01:00, Ales Justin <ales.justin at gmail.com> wrote:
> After fixing that ISPN-2253:
> *
> https://github.com/alesj/infinispan/commit/05229f426e829742902de0305488282b8283b8e5
> (Sanne is working on even cleaner solution)
>
> It now also looks like our CapeDwarf clustering tests have been (almost)
> fixed.
> It now appears as if one node cannot do proper querying:
>
> Deployment dep1 goes to node1, same deployment dep2 goes to node2.
>
> "Failed tests:
> queryOnA(org.jboss.test.capedwarf.cluster.DatastoreTestCase): Number of
> entities: 0"
>
> Where as "queryOnB" doesn't fail.
>
> @Sanne -- do we have any query tests covering this kind of scenario?
>
> I'm using jgroups' auto-master selection.
>
> Tomorrow I'll try fixed jgroups master/slave selection,
> and the new dynamic auto-master selection.
>
> Any ideas still welcome. ;-)
>
> -Ales
>
> ---
>
>     @InSequence(30)
>     @Test
>     @OperateOnDeployment("dep1")
>     public void putStoresEntityOnDepA() throws Exception {
>         Entity entity = createTestEntity("KIND", 1);
>         getService().put(entity);
>         assertStoreContains(entity);
>     }
>
>     @InSequence(31)
>     @Test
>     @OperateOnDeployment("dep2")
>     public void putStoresEntityOnDepB() throws Exception {
>         Entity entity = createTestEntity("KIND", 2);
>         getService().put(entity);
>         assertStoreContains(entity);
>     }
>
>     @InSequence(40)
>     @Test
>     @OperateOnDeployment("dep1")
>     public void getEntityOnDepA() throws Exception {
>         waitForSync();
>
>         Key key = KeyFactory.createKey("KIND", 1);
>         Entity lookup = getService().get(key);
>
>         Assert.assertNotNull(lookup);
>
>         Entity entity = createTestEntity("KIND", 1);
>         Assert.assertEquals(entity, lookup);
>     }
>
>     @InSequence(50)
>     @Test
>     @OperateOnDeployment("dep2")
>     public void getEntityOnDepB() throws Exception {
>         waitForSync();
>
>         Entity entity = createTestEntity("KIND", 1);
>         assertStoreContains(entity);
>     }
>
>     @InSequence(52)
>     @Test
>     @OperateOnDeployment("dep1")
>     public void queryOnA() throws Exception {
>         waitForSync();
>
>         int count = getService().prepare(new
> Query("KIND")).countEntities(Builder.withDefaults());
>         Assert.assertTrue("Number of entities: " + count, count == 2);
>     }
>
>     @InSequence(53)
>     @Test
>     @OperateOnDeployment("dep2")
>     public void queryOnB() throws Exception {
>         waitForSync();
>
>         int count = getService().prepare(new
> Query("KIND")).countEntities(Builder.withDefaults());
>         Assert.assertTrue("Number of entities: " + count, count == 2);
>     }
>