我在我的一个批处理应用程序中使用 map reduce 框架以嵌入式模式运行 Infinispan。如果 2 个客户端同时调用批处理,则此并行执行会导致以下异常:
2013-07-08 11:54:40,346 错误 [main] []:[AbstractStep]:[] 执行步骤 org.infinispan.CacheException 时遇到错误:java.util.concurrent.ExecutionException:org.infinispan.CacheException:org .infinispan.CacheException: 无法在 org.infinispan.distexec.mapreduce.MapReduceTask.execute(MapReduceTask.java:339) 中移动 M/R 任务 f1e249c2-bc87-41e9-9c8d-985b4c2c1ba8 的中间键/值-5.2.5.Final.jar:5.2.5.Final] 在 org.infinispan.distexec.mapreduce.MapReduceTask.execute(MapReduceTask.java:619) ~[infinispan-core-5.2.5.Final.jar:5.2。 5.Final] 在 com.jpmorgan.ct.lri.lcr.rpt.distexec.node.MasterNode.run(MasterNode.java:49)