Hi,
I have a question while using gridgain 8.8.9.
I have CityKey and City objects,when i specified the CityKey.COUNTRYCODE as a
affinity key,
The Expiry Policy didn‘t work.
I put one thousand pieces of data to the cache,the key is CityKey object and
the value is City object ,and the expiry time is one minute.one minute
later,only two pieces of data were removed, then i used cache -scan command in
visor ,all the data were removed ,but if i used cache command , the data would
always exist.
IF I removed the @AffinityKeyMapped annotation on CityKey.COUNTRYCODE,the
expiry policy could work.
I did the same test with gridgain 8.8.18,and the expiry policy worked all the
time.
So I wonder to know if this is a bug in gridgain 8.8.9,
If it’s not a bug, what’s the reason and how to solve it.
Attachments are CityKey and City objects and my test code.
Thanks.
I'll wait for your reply .
Here is the gridgain visor output.
|
visor> cache
Time of the snapshot: 2022-05-12 15:24:33
| Name(@) | Mode | Nodes | Total entries (Heap / Off-heap) | Primar
y entries (Heap / Off-heap) | Hits | Misses | Reads | Writes |
| testcity(@c0) | PARTITIONED | 1 | 1000 (0 / 1000) | min: 1
000 (0 / 1000) | min: 0 | min: 0 | min: 0 | min: 0 |
| | | | | avg: 1
000.00 (0.00 / 1000.00) | avg: 0.00 | avg: 0.00 | avg: 0.00 | avg: 0.00 |
| | | | | max: 1
000 (0 / 1000) | max: 0 | max: 0 | max: 0 | max: 0 |
+-------------------------------------------------------------------------------
----------------------------------------------------------------------------+
Use "-a" flag to see detailed statistics.
visor> cache
Time of the snapshot: 2022-05-12 15:26:50
| Name(@) | Mode | Nodes | Total entries (Heap / Off-heap) | Primar
y entries (Heap / Off-heap) | Hits | Misses | Reads | Writes |
| testcity(@c0) | PARTITIONED | 1 | 998 (0 / 998) | min: 9
98 (0 / 998) | min: 0 | min: 0 | min: 0 | min: 0 |
| | | | | avg: 9
98.00 (0.00 / 998.00) | avg: 0.00 | avg: 0.00 | avg: 0.00 | avg: 0.00 |
| | | | | max: 9
98 (0 / 998) | max: 0 | max: 0 | max: 0 | max: 0 |
+-------------------------------------------------------------------------------
----------------------------------------------------------------------------+
Use "-a" flag to see detailed statistics.
visor> cache -scan
Time of the snapshot: 2022-05-12 15:28:42
+===============================================================+
| # | Name(@) | Mode | Size (Heap / Off-heap) |
+===============================================================+
| 0 | testcity(@c0) | PARTITIONED | min: 998 (0 / 998) |
| | | | avg: 998.00 (0.00 / 998.00) |
| | | | max: 998 (0 / 998) |
+---------------------------------------------------------------+
Choose cache number ('c' to cancel) [c]: 0
Cache: testcity is empty
visor>
|
package com.example.entity;
/**
* City object class.
*/
public class City {
/** */
private String NAME;
/** */
private String DISTRICT;
/** */
private int POPULATION;
public City(String NAME, String DISTRICT, int POPULATION) {
this.NAME = NAME;
this.DISTRICT = DISTRICT;
this.POPULATION = POPULATION;
}
public String getNAME() {
return NAME;
}
public void setNAME(String NAME) {
this.NAME = NAME;
}
public String getDISTRICT() {
return DISTRICT;
}
public void setDISTRICT(String DISTRICT) {
this.DISTRICT = DISTRICT;
}
public int getPOPULATION() {
return POPULATION;
}
public void setPOPULATION(int POPULATION) {
this.POPULATION = POPULATION;
}
@Override
public String toString() {
return "City{" +
"NAME='" + NAME + '\'' +
", DISTRICT='" + DISTRICT + '\'' +
", POPULATION=" + POPULATION +
'}';
}
}package com.example.entity;
import org.apache.ignite.cache.affinity.AffinityKeyMapped;
/**
* City key class to properly work with city objects using key-value and
compute APIs.
* No need to implement hashCode or equals. Ignite does this internally on top
of the serialized data (BinaryObject).
*/
public class CityKey {
/** */
private int ID;
/** */
@AffinityKeyMapped
private String COUNTRYCODE;
public CityKey(int ID, String COUNTRYCODE) {
this.ID = ID;
this.COUNTRYCODE = COUNTRYCODE;
}
public CityKey() {
}
public int getID() {
return ID;
}
public void setID(int ID) {
this.ID = ID;
}
@Override
public String toString() {
return "CityKey{" +
"ID=" + ID +
", COUNTRYCODE='" + COUNTRYCODE + '\'' +
'}';
}
public String getCOUNTRYCODE() {
return COUNTRYCODE;
}
public void setCOUNTRYCODE(String COUNTRYCODE) {
this.COUNTRYCODE = COUNTRYCODE;
}
}package com.example.testshixiao.test;
import com.example.entity.City;
import com.example.entity.CityAll;
import com.example.entity.CityKey;
import org.apache.ignite.Ignition;
import org.apache.ignite.client.ClientCache;
import org.apache.ignite.client.ClientCacheConfiguration;
import org.apache.ignite.client.IgniteClient;
import org.apache.ignite.configuration.ClientConfiguration;
import javax.cache.expiry.CreatedExpiryPolicy;
import javax.cache.expiry.Duration;
import java.util.concurrent.TimeUnit;
public class ThinShixiaoTest01_1 {
public static void main(String[] args) throws Exception {
ClientConfiguration clientConfiguration = new
ClientConfiguration().setAddresses("127.0.0.1:10800");
IgniteClient client = Ignition.startClient(clientConfiguration);
// client.destroyCache("testcity");
ClientCacheConfiguration cacheConfiguration = new
ClientCacheConfiguration().setName("testcity");
cacheConfiguration.setExpiryPolicy(new CreatedExpiryPolicy(new
Duration(TimeUnit.MINUTES, 1)));
ClientCache<CityKey, City> city =
client.getOrCreateCache(cacheConfiguration);
for (int i = 1000000; i < 1001000; ++i) {
City value = new City("henan", "a place", 1000000);
CityKey key = new CityKey(i, "hn" + i);
city.put(key, value);
System.out.println(i);
}
client.close();
}
}
