So i understand the expiration lifespan via configuration has been deprecated in Infinispan 5.1.

Here i am trying a map reduce for a replicated cache whose configuration is :

<clustering mode="replication"> <stateRetrieval timeout="20000" fetchInMemoryState="true"

                              alwaysProvideInMemoryState="true" /> <sync replTimeout="30000" /> </clustering>

public class MyMapReduceExample {

            public static void main(String[] args) {

                    EmbeddedCacheManager manager;

                    long ttlOffset= 2000;

                    try {

                              manager = new DefaultCacheManager("InfinispanCfgForNode1.xml");

                              Cache cache = manager.getCache("InfinispanClientTest");

                              Configuration.CacheMode cacheMode = cache.getConfiguration().getCacheMode();

                              cache.put("LC", "Cat", 3000, TimeUnit.MILLISECONDS);

                              MapReduceTask<Object, Object, Object, Object> t =

                                                           new MapReduceTask<Object, Object, Object, Object>(cache);

                            t.mappedWith(new MyShiftTTLMapper(manager, cache.getName(), ttlOffset)).reducedWith(new MyTestReducer());

                            t.execute();

                    } catch (IOException e) {

                              // TODO Auto-generated catch block

                              e.printStackTrace();

                    }

          }

}

public class MyShiftTTLMapper implements Mapper{

          long ttlOffset;

          private EmbeddedCacheManager manager;

          private String cacheName;

          public MyShiftTTLMapper(){

                    ttlOffset = 0;

          }

          public MyShiftTTLMapper(EmbeddedCacheManager manager, String cacheName,long ttlOffset){

                    System.out.println("Inside constructor of MyTestMapper");

                    this.manager = manager;

                    this.cacheName = cacheName;

                    this.ttlOffset = ttlOffset;

          }

          @Override

          public void map(Object key, Object value, Collector arg2) {

                    Cache cache = this.manager.getCache(this.cacheName);

                    AdvancedCache advancedCache = cache.getAdvancedCache();

                    DataContainer dataContainer = advancedCache.getDataContainer();

                    InternalCacheEntry entry = dataContainer.get(key);

                    long expiryMillis = entry.getExpiryTime();

                    if (expiryMillis > 0) {

                              long newTTL = (expiryMillis- System.currentTimeMillis())+ttlOffset;

                              entry.setLifespan(newTTL);

                    }

                    if(expiryMillis == -1){

                              System.out.println("Entry is set with never expire; Do Nothing");

                              //Do nothing. Since this entry should not expiry at any time

                    }

          }

}

While i tried to use the map reduce on the REPL_SYNC configured cache i get the following error:

Exception in thread "main" java.lang.IllegalStateException: Cache mode should be DIST, rather than REPL_SYNC

          at org.infinispan.distexec.mapreduce.MapReduceTask.ensureProperCacheState(MapReduceTask.java:443)

          at org.infinispan.distexec.mapreduce.MapReduceTask.<init>(MapReduceTask.java:156)

          at com.hp.ispan.mapreduce.ttl.MyMapReduceExample.main(MyMapReduceExample.java:14)

This method works well when the cache configuration is DIST. However for REPLY_SYNC configurations i get errors. What should i do now?