You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@ignite.apache.org by LinusNLucy <gs...@gmail.com> on 2018/06/25 14:20:42 UTC
Distributed Closures Apply method/c#
Hi all
Is there a timeout implied or otherwise with Apply() method for a
Distributed closure? Seems to kick out a exception after roughly two mins.
Thanks
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Re: Distributed Closures Apply method/c#
Posted by Pavel Tupitsyn <pt...@apache.org>.
> ThreadAbortException: Thread was being aborted.
This is not related to Ignite. Thread.Abort is called on .NET side, and
Ignite never does that.
Please check if ASP.NET or some other framework is involved.
On Mon, Jun 25, 2018 at 10:57 PM aealexsandrov <ae...@gmail.com>
wrote:
> Very strange. By default, there is no any timeout. I will take a look more
> carefully.
>
> Also is it possible that you cancel the closure somehow?
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
Re: Distributed Closures Apply method/c#
Posted by aealexsandrov <ae...@gmail.com>.
Very strange. By default, there is no any timeout. I will take a look more
carefully.
Also is it possible that you cancel the closure somehow?
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/
Re: Distributed Closures Apply method/c#
Posted by Immanuel Babu <gs...@gmail.com>.
Some of the code is proprietary, but this is the exception. No, I have not
set a manual timeout
System.Threading.ThreadAbortException: Thread was being aborted.
at System.Threading.Monitor.ObjWait(Boolean exitContext, Int32
millisecondsTimeout, Object obj)
at System.Threading.ManualResetEventSlim.Wait(Int32 millisecondsTimeout,
CancellationToken cancellationToken)
at System.Threading.Tasks.Task.SpinThenBlockingWait(Int32
millisecondsTimeout, CancellationToken cancellationToken)
at System.Threading.Tasks.Task.InternalWait(Int32 millisecondsTimeout,
CancellationToken cancellationToken)
at System.Threading.Tasks.Task`1.GetResultCore(Boolean
waitCompletionNotification)
at
Apache.Ignite.Core.Impl.Compute.Compute.Apply[TArg,TJobRes](IComputeFunc`2
clo, TArg arg)
On Mon, Jun 25, 2018 at 2:37 PM, aealexsandrov <ae...@gmail.com>
wrote:
> Hi,
>
> Could you please provide the exception?
>
> As I see from the code if you didn't set some timeout manual using
> writeTimeout method then Long.MAX_VALUE should be used.
>
> Long timeout = (Long)map.get(TC_TIMEOUT);
>
> long timeout0 = timeout == null || timeout == 0 ? Long.MAX_VALUE :
> timeout;
>
> BR,
> Andrei
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
Re: Distributed Closures Apply method/c#
Posted by aealexsandrov <ae...@gmail.com>.
Hi,
Could you please provide the exception?
As I see from the code if you didn't set some timeout manual using
writeTimeout method then Long.MAX_VALUE should be used.
Long timeout = (Long)map.get(TC_TIMEOUT);
long timeout0 = timeout == null || timeout == 0 ? Long.MAX_VALUE :
timeout;
BR,
Andrei
--
Sent from: http://apache-ignite-users.70518.x6.nabble.com/