fix(Rhea): compatible a bug in jdk 11,more info about bug view issue #…

…990. (#991) Co-authored-by: “yanguanghui” <yanguanghui@betalpha.com>
sofastack · May 24, 2023 · 3d989e3 · 3d989e3
1 parent 3229355
commit 3d989e3
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...eakv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/client/DefaultRheaIterator.java b/...eakv/rheakv-core/src/main/java/com/alipay/sofa/jraft/rhea/client/DefaultRheaIterator.java
@@ -58,7 +58,8 @@ public DefaultRheaIterator(DefaultRheaKVStore rheaKVStore, byte[] startKey, byte
     @Override
     public synchronized boolean hasNext() {
         if (this.buf.isEmpty()) {
-            while (this.endKey == null || BytesUtil.compare(this.cursorKey, this.endKey) < 0) {
+            while (this.endKey == null || (cursorKey != null // fix issue #990
+                   && BytesUtil.compare(this.cursorKey, this.endKey) < 0)) {
                 final List<KVEntry> kvEntries = this.rheaKVStore.singleRegionScan(this.cursorKey, this.endKey,
                     this.bufSize, this.readOnlySafe, this.returnValue);
                 if (kvEntries.isEmpty()) {