Apache Ignite、扫描查询（不带筛选器）和cache上迭代器，都返回空结果集。缓存中的条目数为非零

Question

Apache Ignite版本：2.8.0

在启动第一个ignite cache节点时，在下面的代码段中，给出预期的输出。当第二个ignite缓存加入集群时，第一个代码段中的entries对象为空，而第二个代码段中的iter.hasNext（）给出false。

 Map results = new HashMap();
 QueryCursor<Cache.Entry> entries = binaryCache.query(new ScanQuery(null));
 logger.log(Level.DEBUG, "CacheSize from entrySet: [%s]", binaryCache.size()); // Outputs non zero number. 
 try {
   for (Cache.Entry e : entries) {
     results.put(e.getKey(), e.getValue());
   }
 } catch (IOException e) {
     throw new RuntimeException("Error deserializing ignite entry", e);
 }
 return results.entrySet();

或

    Map results = new HashMap();
    Iterator<Cache.Entry<Object, BinaryObject>> iter = binaryCache.iterator();
    logger.log(Level.DEBUG, "CacheSize from entrySet: [%s]", binaryCache.size()); // Outputs non zero number. 
    try {
      while(iter.hasNext()) {
        Cache.Entry e = iter.next();
        results.put(e.getKey(), e.getValue());
      }
    } catch (IOException e) {
        throw new RuntimeException("Error deserializing ignite entry", e);
    }
    
    return results.entrySet();

当null被传递给ScanQuery时，理想情况下，应该从缓存中提取所有条目。

Answer 1

正如您在第二个示例中注意到的，IgniteCache是可迭代的。如果需要获取存储值，最简单的代码如下所示：

        IgniteCache<Object, BinaryObject> myCache = ignite.getOrCreateCache(ccfg).withKeepBinary();
        for(Cache.Entry<Object, BinaryObject> entry: myCache){
            System.out.println(entry.getKey() + " " + entry.getValue());
        }

        System.out.println("trying again");

        for(Cache.Entry<Object, BinaryObject> entry: myCache){
            System.out.println(entry.getKey() + " " + entry.getValue());
        }