diff --git a/.github/workflows/build-cov.yaml b/.github/workflows/build-cov.yaml index 9fae2187b..d9474a226 100644 --- a/.github/workflows/build-cov.yaml +++ b/.github/workflows/build-cov.yaml @@ -11,9 +11,9 @@ jobs: build: runs-on: ubuntu-latest steps: - - uses: actions/checkout@v3 + - uses: actions/checkout@v4 - name: Set up JDK 17 - uses: actions/setup-java@v3 + uses: actions/setup-java@v4 with: java-version: '17' distribution: 'temurin' diff --git a/base-kv/base-kv-store-server/src/main/java/com/baidu/bifromq/basekv/store/KVRangeStore.java b/base-kv/base-kv-store-server/src/main/java/com/baidu/bifromq/basekv/store/KVRangeStore.java index a73e26a03..868e9d75f 100644 --- a/base-kv/base-kv-store-server/src/main/java/com/baidu/bifromq/basekv/store/KVRangeStore.java +++ b/base-kv/base-kv-store-server/src/main/java/com/baidu/bifromq/basekv/store/KVRangeStore.java @@ -351,6 +351,9 @@ private void receive(StoreMessage storeMessage) { if (payload.hasEnsureRange()) { EnsureRange request = storeMessage.getPayload().getEnsureRange(); mgmtTaskRunner.add(() -> { + if (status.get() != Status.STARTED) { + return CompletableFuture.completedFuture(null); + } KVRangeId rangeId = payload.getRangeId(); IKVRangeFSM range = kvRangeMap.get(rangeId); try {