ignite-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Subash Chaturanga <subash...@gmail.com>
Subject Re: Ignite Expiry Inconsistency with Native Persistence
Date Mon, 19 Mar 2018 08:45:34 GMT
If you can send me the working code I can try to compare what’s missing.

On Thu, Mar 15, 2018 at 10:14 AM Subash Chaturanga <subashsdm@gmail.com>
wrote:

> 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.kulichenko@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
>
-- 
/subash

Mime
View raw message