Re: Adding entry to partition that is concurrently evicted

[Weizhou He]

Hi,

All error log was pasted.
I used spring to launch Ignite, so all config is defined in java. As below,

@Bean("igniteConfiguration")
IgniteConfiguration igniteConfiguration(@Value("${zookeeper.host}")
String zkHost) {
    IgniteConfiguration igniteConfiguration = new IgniteConfiguration();
    igniteConfiguration.setClientMode(false);

    ClientConnectorConfiguration clientConnectorConfiguration = new
ClientConnectorConfiguration();
    clientConnectorConfiguration.setPort(10801);
    
igniteConfiguration.setClientConnectorConfiguration(clientConnectorConfiguration);

    // common ignite configuration
    igniteConfiguration.setMetricsLogFrequency(0);
    igniteConfiguration.setQueryThreadPoolSize(2);
    igniteConfiguration.setDataStreamerThreadPoolSize(1);
    igniteConfiguration.setManagementThreadPoolSize(2);
    igniteConfiguration.setPublicThreadPoolSize(2);
    igniteConfiguration.setSystemThreadPoolSize(2);
    igniteConfiguration.setRebalanceThreadPoolSize(1);
    igniteConfiguration.setAsyncCallbackPoolSize(2);
    igniteConfiguration.setPeerClassLoadingEnabled(false);

    // memory configuration
    DataStorageConfiguration storageCfg = new DataStorageConfiguration();
    storageCfg.getDefaultDataRegionConfiguration().setMaxSize(4L *
1024 * 1024 * 1024);
    
storageCfg.getDefaultDataRegionConfiguration().setPageEvictionMode(DataPageEvictionMode.RANDOM_LRU);
    igniteConfiguration.setDataStorageConfiguration(storageCfg);

    BinaryConfiguration binaryConfiguration = new BinaryConfiguration();
    binaryConfiguration.setCompactFooter(false);
    igniteConfiguration.setBinaryConfiguration(binaryConfiguration);

    ZookeeperDiscoverySpi zkDiscoSpi = new ZookeeperDiscoverySpi();

    zkDiscoSpi.setZkConnectionString(zkHost);
    zkDiscoSpi.setSessionTimeout(30_000);
    if(debug){
        zkDiscoSpi.setZkRootPath("/ignite-debug");
    }else{
        zkDiscoSpi.setZkRootPath("/ignite");
    }
    zkDiscoSpi.setJoinTimeout(10_000);
    igniteConfiguration.setDiscoverySpi(zkDiscoSpi);

    TcpCommunicationSpi tcpCommunicationSpi = new TcpCommunicationSpi();
    tcpCommunicationSpi.setLocalPort(48500);

    igniteConfiguration.setCommunicationSpi(tcpCommunicationSpi);

    return igniteConfiguration;
}

@Bean(destroyMethod = "close")
Ignite labelIgnite(@Qualifier("igniteConfiguration")
IgniteConfiguration igniteConfiguration) {
    CacheConfiguration fiveMinutesCacheConfiguration = new CacheConfiguration();
    fiveMinutesCacheConfiguration.setName("FiveMinutes");
    fiveMinutesCacheConfiguration.setCacheMode(CacheMode.PARTITIONED);
    fiveMinutesCacheConfiguration.setBackups(0);
    fiveMinutesCacheConfiguration.setAtomicityMode(CacheAtomicityMode.ATOMIC);
    
fiveMinutesCacheConfiguration.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(Duration.FIVE_MINUTES));
    CacheConfiguration oneMinuteCacheConfiguration = new CacheConfiguration();
    oneMinuteCacheConfiguration.setName("OneMinute");
    oneMinuteCacheConfiguration.setCacheMode(CacheMode.PARTITIONED);
    oneMinuteCacheConfiguration.setBackups(0);
    oneMinuteCacheConfiguration.setAtomicityMode(CacheAtomicityMode.ATOMIC);
    
oneMinuteCacheConfiguration.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(Duration.ONE_MINUTE));

    CacheConfiguration oneDayConfiguration = new CacheConfiguration();
    oneDayConfiguration.setName("OneDay");
    oneDayConfiguration.setCacheMode(CacheMode.PARTITIONED);
    oneDayConfiguration.setBackups(0);
    oneDayConfiguration.setAtomicityMode(CacheAtomicityMode.ATOMIC);
    
oneDayConfiguration.setExpiryPolicyFactory(CreatedExpiryPolicy.factoryOf(Duration.ONE_DAY));

    final Ignite start = Ignition.start(igniteConfiguration);
    start.addCacheConfiguration(fiveMinutesCacheConfiguration);
    start.addCacheConfiguration(oneMinuteCacheConfiguration);
    start.addCacheConfiguration(oneDayConfiguration);

    return start;
}


And I will try to create table each time I start spring process.

try {
    jdbcTemplate.execute("CREATE TABLE IF NOT EXISTS Monitor" +
getType() + " (\n" +
            "hostip VARCHAR(32),\n" +
            "tid BIGINT,\n" +
            "type VARCHAR(32),\n" +
            "request VARCHAR(32),\n" +
            "parametermap VARCHAR(MAX),\n" +
            "PRIMARY KEY(hostip, tid, type, request)\n" +
            ") WITH \"template=FiveMinutes\"");
} catch (Exception e) {
    e.printStackTrace();
}


aealexsandrov <aealexsand...@gmail.com> 于2018年10月18日周四 下午5:15写道：

> Hi,
>
> Could you please attach the configuration of the cluster and full log?
>
> BR,
> Andrei
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>