[BUG] Can't read any record from the block
Closed this issue · 0 comments
superhx commented
stream fetch [17408, 21760) 21760 fail (com.automq.stream.s3.S3Stream)
java.util.concurrent.CompletionException: com.automq.stream.s3.exceptions.AutoMQException: [UNEXPECTED] Can't read any record from the blocks
at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:332)
at java.base/java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:347)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:874)
at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162)
at com.automq.stream.s3.cache.blockcache.StreamReader.lambda$read$1(StreamReader.java:121)
at com.automq.stream.utils.FutureUtil.exec(FutureUtil.java:77)
at com.automq.stream.s3.cache.blockcache.StreamReader.lambda$read$2(StreamReader.java:108)
at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:863)
at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:841)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:2162)
at com.automq.stream.s3.cache.blockcache.StreamReader.lambda$read0$9(StreamReader.java:203)
at java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2147)
at com.automq.stream.s3.cache.blockcache.StreamReader.lambda$getBlocks0$13(StreamReader.java:310)
at java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(CompletableFuture.java:718)
at java.base/java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:482)
at com.automq.stream.utils.threads.EventLoop.run(EventLoop.java:48)
Caused by: com.automq.stream.s3.exceptions.AutoMQException: [UNEXPECTED] Can't read any record from the blocks
... 8 more