Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Replay ack and changeInvisibleDuration operation failed #229

Closed
daniel-y opened this issue Oct 10, 2023 · 1 comment · Fixed by #267
Closed

Replay ack and changeInvisibleDuration operation failed #229

daniel-y opened this issue Oct 10, 2023 · 1 comment · Fixed by #267
Assignees
@ShadowySpirits @TheR1sing3un
Labels
bug Something isn't working

Comments

@daniel-y
Copy link
Contributor 

2023-10-10 21:31:18 ERROR s3-storage-main - [DefaultStateMachine-1-0]: Replay ack operation failed
com.automq.rocketmq.store.exception.StoreException: Ack operation failed, check point not found
        at com.automq.rocketmq.store.DefaultMessageStateMachine.replayAckOperation(DefaultMessageStateMachine.java:289)
        at com.automq.rocketmq.store.service.StreamOperationLogService.replay(StreamOperationLogService.java:166)
        at com.automq.rocketmq.store.service.StreamOperationLogService.doReplay(StreamOperationLogService.java:148)
        at com.automq.rocketmq.store.service.StreamOperationLogService.lambda$logAckOperation$5(StreamOperationLogService.java:113)
        at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
        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.S3Storage.handleAppendCallback0(S3Storage.java:313)
        at com.automq.stream.s3.S3Storage.lambda$handleAppendCallback$13(S3Storage.java:301)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
        at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-10 21:31:22 ERROR s3-storage-main - [DefaultStateMachine-1-0]: Replay ack operation failed
com.automq.rocketmq.store.exception.StoreException: Ack operation failed, check point not found
        at com.automq.rocketmq.store.DefaultMessageStateMachine.replayAckOperation(DefaultMessageStateMachine.java:289)
        at com.automq.rocketmq.store.service.StreamOperationLogService.replay(StreamOperationLogService.java:166)
        at com.automq.rocketmq.store.service.StreamOperationLogService.doReplay(StreamOperationLogService.java:148)
        at com.automq.rocketmq.store.service.StreamOperationLogService.lambda$logAckOperation$5(StreamOperationLogService.java:113)
        at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
        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.S3Storage.handleAppendCallback0(S3Storage.java:313)
        at com.automq.stream.s3.S3Storage.lambda$handleAppendCallback$13(S3Storage.java:301)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
        at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        at java.base/java.lang.Thread.run(Thread.java:833)
2023-10-10 21:32:10 ERROR s3-storage-main - [DefaultStateMachine-1-0]: Replay ack operation failed
com.automq.rocketmq.store.exception.StoreException: Ack operation failed, check point not found
        at com.automq.rocketmq.store.DefaultMessageStateMachine.replayAckOperation(DefaultMessageStateMachine.java:289)
        at com.automq.rocketmq.store.service.StreamOperationLogService.replay(StreamOperationLogService.java:166)
        at com.automq.rocketmq.store.service.StreamOperationLogService.doReplay(StreamOperationLogService.java:148)
        at com.automq.rocketmq.store.service.StreamOperationLogService.lambda$logAckOperation$5(StreamOperationLogService.java:113)
        at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
        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.S3Storage.handleAppendCallback0(S3Storage.java:313)
        at com.automq.stream.s3.S3Storage.lambda$handleAppendCallback$13(S3Storage.java:301)
        at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
        at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:264)
        at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
        at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
        at java.base/java.lang.Thread.run(Thread.java:833)
@daniel-y daniel-y added the bug Something isn't working label Oct 10, 2023
@ShadowySpirits
Copy link
Contributor

Replay changeInvisibleDuration also failed.

2023-10-11 10:22:26 ERROR s3-storage-main - [DefaultStateMachine-1-0]: Replay change invisible duration operation failed
com.automq.rocketmq.store.exception.StoreException: Change invisible duration operation failed, check point not found
	at com.automq.rocketmq.store.DefaultMessageStateMachine.replayChangeInvisibleDurationOperation(DefaultMessageStateMachine.java:347)
	at com.automq.rocketmq.store.service.StreamOperationLogService.replay(StreamOperationLogService.java:168)
	at com.automq.rocketmq.store.service.StreamOperationLogService.doReplay(StreamOperationLogService.java:148)
	at com.automq.rocketmq.store.service.StreamOperationLogService.lambda$logChangeInvisibleDurationOperation$6(StreamOperationLogService.java:120)
	at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:646)
	at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:510)
	at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2179)
	at com.automq.stream.s3.S3Storage.handleAppendCallback0(S3Storage.java:313)
	at com.automq.stream.s3.S3Storage.lambda$handleAppendCallback$13(S3Storage.java:301)
	at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:577)
	at java.base/java.util.concurrent.FutureTask.run$$$capture(FutureTask.java:317)
	at java.base/java.util.concurrent.FutureTask.run(FutureTask.java)
	at java.base/java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
	at java.base/java.lang.Thread.run(Thread.java:1589)

@ShadowySpirits ShadowySpirits self-assigned this Oct 11, 2023
@ShadowySpirits ShadowySpirits changed the title Replay ack operation failed Replay ack and changeInvisibleDuration operation failed Oct 11, 2023
This was referenced Oct 11, 2023
Closed
Merged
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Assignees

@ShadowySpirits ShadowySpirits

@TheR1sing3un TheR1sing3un

Labels
bug Something isn't working
Projects
None yet
Milestone
No milestone
Development

Successfully merging a pull request may close this issue.

fix(store): fix ack and change invisible duration AutoMQ/automq-for-rocketmq
3 participants
@ShadowySpirits @TheR1sing3un @daniel-y