Well, in the code you've shared you're not waiting between puts and checks
after that. I used this expiry policy for cache: FactoryBuilder.factoryOf(new
CreatedExpiryPolicy(new Duration(SECONDS, 1))))
and added Thread.sleep(2000) before puts and gets in your code and
ExpiryPolicy world for me without any issues.
Evgenii
вт, 25 авг. 2020 г. в 02:31, kay <goek...@gmail.com>:
> Hello, here is my code for test.
>
>
> public class CachePutLoopTest {
>
> /**
> * @param args
> */
> public static void main(String[] args) {
> /*
> cache의 ip, port 파라미터를 받아서 특정노드에 데이터를 저장
> */
> System.out.println("┌──────────────────────── Cache Rebalance Put/Get
> Start ────────────────────────");
> ClientConfiguration cfg = new
> ClientConfiguration().setAddresses(args[0]);
> IgniteClient igniteClient = Ignition.startClient(cfg);
>
> ClientCache<Integer, Integer> testCache = igniteClient.cache(args[1]);
> System.out.println("│ ■ Cache Name : " + testCache.getName());
> System.out.println("│ ■ Cache Put Start");
>
> for(int i = 0; i < Integer.parseInt(args[2]); i++) {
> testCache.put(i, i+1);
> }// end for(i)
>
> System.out.println("│ ■ Cache Put End");
> System.out.println("│ ■ Cache Get Start");
> for(int i = 0; i < Integer.parseInt(args[2]); i++) {
> System.out.println("│ ■ Data Get : "+testCache.get(i));
> }// end for(i)
> System.out.println("│ ■ Cache Get End");
> System.out.println("└──────────────────────── Cache Rebalance Put/Get
> End
> ────────────────────────");
> System.out.println();
> System.out.println();
>
>
> }// end of main
>
> }// end of CachePutLoopTest.java
>
>
> and I use GridGainWebConsole for monitoring.
> so I figured out remain cache data.
>
>
> Thank you so much.
>
>
>
> --
> Sent from: http://apache-ignite-users.70518.x6.nabble.com/
>
