Re: Distributed Closures Apply method/c#

2018-06-25 Thread Pavel Tupitsyn 
>  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 
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#

2018-06-25 Thread aealexsandrov 
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#

2018-06-25 Thread Immanuel Babu 
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 
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#

2018-06-25 Thread aealexsandrov 
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/

Distributed Closures Apply method/c#

2018-06-25 Thread LinusNLucy 
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/