You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@ignite.apache.org by fatality <fa...@gmail.com> on 2017/06/04 17:40:37 UTC

Ignite Transactional From DataStream Receiver not supported?

Hi 

I am using igniteDataStreamer and would like to know if it is possible to
use transactions from closures.

Unfortunately, when running from different IgniteDataStreamer threads for
the same record in the cache, Ignite does not throw any
TransactionOptimisticException even though CacheConfiguration atomicityMode
is TRANSACTIONAL. 

try (Transaction t =
ignite.transactions().txStart(TransactionConcurrency.OPTIMISTIC,
TransactionIsolation.SERIALIZABLE)) {
            try {
                cache.putAll(update);
                t.commit();
            catch (TransactionOptimisticException toe) {
                LOG.error("TransactionOptimisticException Could not put all
the profiles",toe);
            }
        }



--
View this message in context: http://apache-ignite-users.70518.x6.nabble.com/Ignite-Transactional-From-DataStream-Receiver-not-supported-tp13359.html
Sent from the Apache Ignite Users mailing list archive at Nabble.com.