Hello, I've tried in sample project and worked as expected. In my original case I had updated records in database using arbitrary partition ids. I had misunderstood. I should have updated records according to affinity function. Thank you Regards, Serdar
On 20 March 2018 at 16:57, slava.koptilin <[email protected]> wrote: > Hello serdar, > > Well, I just checked your project and it seems I found the root cause of > that behavior. > UserInfoGenerator uses wrong logic in order to generate the partitionId. > The partitionId must be equal the value that is returned by corresponding > affinity function, i.e. > > partitionId = > ignite.affinity(UserInfo.class.getName()).partition(iserInfo.getUserid()) > > Best regards, > Slava. > > > > -- > Sent from: http://apache-ignite-users.70518.x6.nabble.com/ >
