Mailing-List: contact user-help@ignite.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@ignite.apache.org
MIME-Version: 1.0
In-Reply-To: <1509239391918-0.post@n6.nabble.com>
References: <1509239391918-0.post@n6.nabble.com>
From: Andrey Mashenkov <andrey.mashenkov@gmail.com>
Date: Fri, 3 Nov 2017 20:15:45 +0300
Message-ID: <CANCAXEFq+Z_4RBiiKzBPeNeMRLQVevy+g+_V3OAXRhWwd+aFqA@mail.gmail.com>
Subject: Re: Threads waiting
To: user@ignite.apache.org
Content-Type: multipart/alternative; boundary="001a113dc5f45ab500055d17417f"
archived-at: Fri, 03 Nov 2017 17:15:54 -0000

--001a113dc5f45ab500055d17417f
Content-Type: text/plain; charset="UTF-8"

Hi,

Your thread is waiting for partition exchange that possibly hangs due to
some reason.

Is it possible, to share logs and thread dumps at a time when you observed
hanging?

On Sun, Oct 29, 2017 at 4:09 AM, naresh.goty <gnr.springs@gmail.com> wrote:

> Hi,
>
> We are seeing threads blocked when reading (only reads not writes) for data
> from cache using Ignite.affinitiyCall().
>
> Scenario:
> 1) Two nodes are started in a cluster. Perform cache reads using
> Ignite.affinityCall() and it works.
> 2) One node is stopped, and perform cache read again using
> Ignite.affinityCall() and it is blocked.
>
>  java.lang.Thread.State: WAITING (parking)
>         at sun.misc.Unsafe.park(Native Method)
>         at java.util.concurrent.locks.LockSupport.park(LockSupport.
> java:304)
>         at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get0(GridFutureAdapter.java:176)
>         at
> org.apache.ignite.internal.util.future.GridFutureAdapter.
> get(GridFutureAdapter.java:139)
>         at
> org.apache.ignite.internal.processors.affinity.
> GridAffinityAssignmentCache.awaitTopologyVersion(
> GridAffinityAssignmentCache.java:557)
>         at
> org.apache.ignite.internal.processors.affinity.
> GridAffinityAssignmentCache.cachedAffinity(GridAffinityAssignmentCache.
> java:468)
>         at
> org.apache.ignite.internal.processors.cache.GridCacheAffinityManager.
> assignment(GridCacheAffinityManager.java:238)
>         at
> org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.
> affinityCache(GridAffinityProcessor.java:375)
>         at
> org.apache.ignite.internal.processors.affinity.GridAffinityProcessor.
> affinityKey(GridAffinityProcessor.java:306)
>         at
> org.apache.ignite.internal.IgniteComputeImpl.affinityCallAsync0(
> IgniteComputeImpl.java:333)
>         at
> org.apache.ignite.internal.IgniteComputeImpl.affinityCall(
> IgniteComputeImpl.java:301)
>
>
> Thanks,
> Naresh
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>


-- 
Best regards,
Andrey V. Mashenkov

--001a113dc5f45ab500055d17417f
Content-Type: text/html; charset="UTF-8"
Content-Transfer-Encoding: quoted-printable

<div dir=3D"ltr">Hi,<div><br></div><div>Your thread is waiting for partitio=
n exchange that possibly hangs due to some reason.</div><div><br></div><div=
>Is it possible, to share logs and thread dumps at a time when you observed=
 hanging?</div></div><div class=3D"gmail_extra"><br><div class=3D"gmail_quo=
te">On Sun, Oct 29, 2017 at 4:09 AM, naresh.goty <span dir=3D"ltr">&lt;<a h=
ref=3D"mailto:gnr.springs@gmail.com" target=3D"_blank">gnr.springs@gmail.co=
m</a>&gt;</span> wrote:<br><blockquote class=3D"gmail_quote" style=3D"margi=
n:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Hi,<br>
<br>
We are seeing threads blocked when reading (only reads not writes) for data=
<br>
from cache using Ignite.affinitiyCall().<br>
<br>
Scenario:<br>
1) Two nodes are started in a cluster. Perform cache reads using<br>
Ignite.affinityCall() and it works.<br>
2) One node is stopped, and perform cache read again using<br>
Ignite.affinityCall() and it is blocked.<br>
<br>
=C2=A0java.lang.Thread.State: WAITING (parking)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at sun.misc.Unsafe.park(Native Method)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at java.util.concurrent.locks.<wbr>LockSupport.=
park(LockSupport.<wbr>java:304)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>util.future.GridFutureAdapter.<wbr>get0(Gri=
dFutureAdapter.java:<wbr>176)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>util.future.GridFutureAdapter.<wbr>get(Grid=
FutureAdapter.java:<wbr>139)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>processors.affinity.<wbr>GridAffinityAssign=
mentCache.<wbr>awaitTopologyVersion(<wbr>GridAffinityAssignmentCache.<wbr>j=
ava:557)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>processors.affinity.<wbr>GridAffinityAssign=
mentCache.<wbr>cachedAffinity(<wbr>GridAffinityAssignmentCache.<wbr>java:46=
8)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>processors.cache.<wbr>GridCacheAffinityMana=
ger.<wbr>assignment(<wbr>GridCacheAffinityManager.java:<wbr>238)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>processors.affinity.<wbr>GridAffinityProces=
sor.<wbr>affinityCache(<wbr>GridAffinityProcessor.java:<wbr>375)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>processors.affinity.<wbr>GridAffinityProces=
sor.<wbr>affinityKey(<wbr>GridAffinityProcessor.java:<wbr>306)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>IgniteComputeImpl.<wbr>affinityCallAsync0(<=
wbr>IgniteComputeImpl.java:333)<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 at<br>
org.apache.ignite.internal.<wbr>IgniteComputeImpl.<wbr>affinityCall(<wbr>Ig=
niteComputeImpl.java:301)<br>
<br>
<br>
Thanks,<br>
Naresh<br>
<br>
<br>
<br>
--<br>
Sent from: <a href=3D"http://apache-ignite-users.70518.x6.nabble.com/" rel=
=3D"noreferrer" target=3D"_blank">http://apache-ignite-users.<wbr>70518.x6.=
nabble.com/</a><br>
</blockquote></div><br><br clear=3D"all"><div><br></div>-- <br><div class=
=3D"gmail_signature" data-smartmail=3D"gmail_signature"><div dir=3D"ltr"><d=
iv>Best regards,<br>Andrey V. Mashenkov<br></div></div></div>
</div>

--001a113dc5f45ab500055d17417f--