We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents b7e559d + ef50f16 commit c5c9ac9Copy full SHA for c5c9ac9
src/main/java/io/openmessaging/storage/dledger/store/file/DLedgerMmapFileStore.java
@@ -218,6 +218,10 @@ public void recover() {
218
}
219
220
int size = byteBuffer.getInt();
221
+ if(size == 0){
222
+ logger.info("Recover data file to the end of {} ", mappedFile.getFileName());
223
+ break;
224
+ }
225
long entryIndex = byteBuffer.getLong();
226
long entryTerm = byteBuffer.getLong();
227
long pos = byteBuffer.getLong();
0 commit comments