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

…990.
sofastack · May 22, 2023 · 081fbd1 · 081fbd1
1 parent 26977b0
commit 081fbd1
Showing 1 changed file with 2 additions and 2 deletions.
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
@@ -26,7 +26,6 @@
 import com.alipay.sofa.jraft.util.BytesUtil;
 
 /**
- *
  * @author jiachun.fjc
  */
 public class DefaultRheaIterator implements RheaIterator<KVEntry> {
@@ -58,7 +57,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()) {