トランザクションからのIgniteトランザクションDataStream Receiverはサポートされていませんか？

Question

私はigniteDataStreamerを使用しており、クロージャからのトランザクションを使用できるかどうかを知りたいと思います。

残念ながら、CacheRefigiverのキャッシュ（receive（）メソッド）で更新する同じレコードの異なるIgniteDataStreamerスレッドから実行すると、IgniteはCacheConfiguration atomicityModeがTRANSACTIONALであってもTransactionOptimisticExceptionをスローしません。

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); 
      } 
     } 

Answer 1

データストリーマーはトランザクションではありません。単一のトランザクションで更新を実行するには、同じノードと同じスレッドで更新を開始する必要があります。詳細については、ここをクリックしてください：https://apacheignite.readme.io/docs/transactions