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: <1509702187097-0.post@n6.nabble.com>
References: <1509702187097-0.post@n6.nabble.com>
From: Evgenii Zhuravlev <e.zhuravlev.wk@gmail.com>
Date: Fri, 3 Nov 2017 13:40:44 +0300
Message-ID: <CAHjLBP8GTNoqQB=n4oeEPM58oO5ZL=9gJS26HVAa84p3hPok4g@mail.gmail.com>
Subject: Re: Transactions and IgniteQueue
To: user@ignite.apache.org
Content-Type: multipart/alternative; boundary="001a11440fbcaa15c6055d11bca7"
archived-at: Fri, 03 Nov 2017 10:40:57 -0000

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

Hi Arun,

As for now, IgniteTransaction works only for caches. You can find
information about it in documentation:
https://apacheignite.readme.io/docs/transactions#section-ignitetransactions

Evgenii

2017-11-03 12:43 GMT+03:00 arunkjn <arunkjn@gmail.com>:

> Hi,
>
> I am using an optimistic transaction with serializable isolation level on a
> transactional cache as follows-
>
> while (true){
>                 try(Transaction tx =
> ignite.transactions().txStart(TransactionConcurrency.OPTIMISTIC,
> TransactionIsolation.SERIALIZABLE)){
>
>                     // update all keys of workflow run state corresponding
> to this event
>                     flowRunStateIds.stream().forEach(flowRunStateId -> {
>                         FlowRunState state =
> workflowRunStateIgniteCache.get(flowRunStateId);
>                         try {
>                             state.getFlowRunEvents().put(event);
>                         } catch (InterruptedException e) {
>                             e.printStackTrace();
>                         }
>                         workflowRunStateIgniteCache.put(flowRunStateId,
> state);
>                     });
>
>                     updatedFlows.stream().forEach(workflowFlow ->
> updatedFlowsIgniteQueue.put(workflowFlow));
>
>                     tx.commit();
>                     break;
>                 }
>                 catch (TransactionOptimisticException e){
>                     // todo: emit a monitoring metric TRANSACTIONS_FAILED
> here
>                     System.out.println("Transaction failed. Retrying...");
>                 }
>             }
>
> Inside the transaction I am updating the cache values and also updating an
> IgniteQueue updatedFlowsIgniteQueue. If the transaction fails at the time
> of
> commit, the transactional cache will not be updated. Is the same also true
> for IgniteQueue? Also, will my queue be locked during the duration of the
> transaction?
>
> Thanks,
> Arun
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>

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

<div dir=3D"ltr">Hi Arun,<div><br></div><div>As for now, IgniteTransaction =
works only for caches. You can find information about it in documentation:=
=C2=A0<a href=3D"https://apacheignite.readme.io/docs/transactions#section-i=
gnitetransactions">https://apacheignite.readme.io/docs/transactions#section=
-ignitetransactions</a></div><div><br></div><div>Evgenii</div></div><div cl=
ass=3D"gmail_extra"><br><div class=3D"gmail_quote">2017-11-03 12:43 GMT+03:=
00 arunkjn <span dir=3D"ltr">&lt;<a href=3D"mailto:arunkjn@gmail.com" targe=
t=3D"_blank">arunkjn@gmail.com</a>&gt;</span>:<br><blockquote class=3D"gmai=
l_quote" style=3D"margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left=
:1ex">Hi,<br>
<br>
I am using an optimistic transaction with serializable isolation level on a=
<br>
transactional cache as follows-<br>
<br>
while (true){<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 try(Transaction tx =
=3D<br>
ignite.transactions().txStart(<wbr>TransactionConcurrency.<wbr>OPTIMISTIC,<=
br>
TransactionIsolation.<wbr>SERIALIZABLE)){<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 // up=
date all keys of workflow run state corresponding<br>
to this event<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 flowR=
unStateIds.stream().<wbr>forEach(flowRunStateId -&gt; {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 FlowRunState state =3D<br>
workflowRunStateIgniteCache.<wbr>get(flowRunStateId);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 try {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 state.getFlowRunEvents().put(<wbr>event);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 } catch (InterruptedException e) {<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 =C2=A0 =C2=A0 e.printStackTrace();<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 }<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=
=A0 =C2=A0 workflowRunStateIgniteCache.<wbr>put(flowRunStateId,<br>
state);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 });<b=
r>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 updat=
edFlows.stream().forEach(<wbr>workflowFlow -&gt;<br>
updatedFlowsIgniteQueue.put(<wbr>workflowFlow));<br>
<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 tx.co=
mmit();<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 break=
;<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 catch (<wbr>Transac=
tionOptimisticException e){<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 // to=
do: emit a monitoring metric TRANSACTIONS_FAILED<br>
here<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 Syste=
m.out.println(&quot;<wbr>Transaction failed. Retrying...&quot;);<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
=C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 }<br>
<br>
Inside the transaction I am updating the cache values and also updating an<=
br>
IgniteQueue updatedFlowsIgniteQueue. If the transaction fails at the time o=
f<br>
commit, the transactional cache will not be updated. Is the same also true<=
br>
for IgniteQueue? Also, will my queue be locked during the duration of the<b=
r>
transaction?<br>
<br>
Thanks,<br>
Arun<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></div>

--001a11440fbcaa15c6055d11bca7--