Here’s my code.

*public static void *main(String[] args) *throws*InterruptedException {

        String region = *"4GRegion"*;
        String cacheName = *"bar2"*;
        String path = *"C:**\\**dev**\\**dpsrc**\\**simple-java**\\**work"*;

        DataStorageConfiguration storageCfg = *new*
DataStorageConfiguration();

        DataRegionConfiguration regionCfg = *new*DataRegionConfiguration();
        regionCfg.setName(region);
        regionCfg.setInitialSize(10L * 1024 *1024);
        regionCfg.setMaxSize(100L * 1024 * 1024);
        regionCfg.setPageEvictionMode(DataPageEvictionMode.*RANDOM_LRU*);
        regionCfg.setPersistenceEnabled(*true*);

        storageCfg.setDataRegionConfigurations(regionCfg);

        IgniteConfiguration cfg = *new*IgniteConfiguration();
        cfg.setWorkDirectory(path);
        cfg.setDataStorageConfiguration(storageCfg);
        TcpDiscoverySpi spi = *new*TcpDiscoverySpi();
        TcpDiscoveryVmIpFinder ipFinder = *new*TcpDiscoveryVmIpFinder();
        ipFinder.setAddresses(Arrays.*asList*(*"127.0.0.1:47500..47509"*));
        spi.setIpFinder(ipFinder);
        cfg.setDiscoverySpi(spi);

        Ignite ignite = Ignition.*start*(cfg);

        ignite.active(*true*);

        CacheConfiguration<String,String> cc = *new *CacheConfiguration<>();
        cc.setDataRegionName(region);
        cc.setPartitionLossPolicy(PartitionLossPolicy.*READ_WRITE_ALL*);
        cc.setName(cacheName);
        cc.setCacheMode(CacheMode.*PARTITIONED*);
        cc.setGroupName(cacheName);
        cc.setExpiryPolicyFactory(CreatedExpiryPolicy.*factoryOf*(*new*
Duration(TimeUnit.*SECONDS*, 15)));
        cc.setStatisticsEnabled(*true*);
        ignite.resetLostPartitions(Arrays.*asList*(*new *
String[]{cacheName}));




*//        ignite.getOrCreateCache(cc).put("A1","V1");//
ignite.getOrCreateCache(cc).put("A2","V2");        *System.*out*.println(
*new *Date().toString() + *"---->>>" *+ ignite.getOrCreateCache(cc).get(
*"A1"*));
        System.*out*.println(*new *Date().toString() + *"---->>>" *+
ignite.getOrCreateCache(cc).get(*"A2"*));

        Thread.*sleep*(20*1000);

        System.*out*.println(*new *Date().toString() + *"---->>>" *+
ignite.getOrCreateCache(cc).get(*"A1"*));
        System.*out*.println(*new *Date().toString() + *"---->>>" *+
ignite.getOrCreateCache(cc).get(*"A2"*));
    }



On Wed, Mar 14, 2018 at 5:07 PM vkulichenko <valentin.kuliche...@gmail.com>
wrote:

> Subash,
>
> This is weird, I'm doing exactly the same and not able to reproduce the
> issue. Can you share your whole test so that I can run it as-is?
>
> -Val
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
-- 
/subash

Reply via email to