The rewind operation happened on the transaction executor (pulsar-transaction-executor-17-1), which could be a deadlock:

2025-06-09T09:14:12,978+0000 [pulsar-transaction-executor-17-1] WARN  org.apache.pulsar.broker.transaction.buffer.impl.TopicTransactionBuffer - Closing topic persistent://public/default/my-single-partitioned-topic-partition-1 due to read transaction buffer snapshot while recovering the transaction buffer throw exception
java.util.concurrent.TimeoutException: null
	at java.base/java.util.concurrent.CompletableFuture.timedGet(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source) ~[?:?]
	at org.apache.pulsar.broker.transaction.buffer.impl.TableView.wait(TableView.java:96) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at org.apache.pulsar.broker.transaction.buffer.impl.TableView.readLatest(TableView.java:63) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at org.apache.pulsar.broker.transaction.buffer.impl.SingleSnapshotAbortedTxnProcessorImpl.lambda$recoverFromSnapshot$1(SingleSnapshotAbortedTxnProcessorImpl.java:93) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty-netty-common-4.1.121.Final.jar:4.1.121.Final]
	at java.base/java.lang.Thread.run(Unknown Source) [?:?]
2025-06-09T09:14:12,981+0000 [pulsar-transaction-executor-17-1] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/default/my-single-partitioned-topic-partition-1][my-sub] Successfully closed subscription [ManagedCursorImpl{ledger=public/default/persistent/my-single-partitioned-topic-partition-1, name=my-sub, ackPos=540:-1, readPos=540:0}]
2025-06-09T09:14:12,981+0000 [pulsar-transaction-executor-17-1] INFO  org.apache.pulsar.broker.service.persistent.PersistentSubscription - [persistent://public/default/my-single-partitioned-topic-partition-1][my-sub] Successfully closed the subscription
2025-06-09T09:14:12,983+0000 [pulsar-transaction-executor-17-1] INFO  org.apache.bookkeeper.mledger.impl.ManagedLedgerImpl - [public/default/persistent/my-single-partitioned-topic-partition-1] Closing managed ledger
2025-06-09T09:14:12,984+0000 [pulsar-transaction-executor-17-1] ERROR org.apache.pulsar.broker.transaction.buffer.impl.TopicTransactionBuffer - [persistent://public/default/my-single-partitioned-topic-partition-1]Transaction buffer failed to recover snapshot!
java.util.concurrent.CompletionException: java.util.concurrent.TimeoutException
	at java.base/java.util.concurrent.CompletableFuture.encodeThrowable(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.completeThrowable(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture$UniAccept.tryFire(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.postComplete(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.completeExceptionally(Unknown Source) ~[?:?]
	at org.apache.pulsar.broker.transaction.buffer.impl.SingleSnapshotAbortedTxnProcessorImpl.lambda$recoverFromSnapshot$1(SingleSnapshotAbortedTxnProcessorImpl.java:103) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source) ~[?:?]
	at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.netty-netty-common-4.1.121.Final.jar:4.1.121.Final]
	at java.base/java.lang.Thread.run(Unknown Source) [?:?]
Caused by: java.util.concurrent.TimeoutException
	at java.base/java.util.concurrent.CompletableFuture.timedGet(Unknown Source) ~[?:?]
	at java.base/java.util.concurrent.CompletableFuture.get(Unknown Source) ~[?:?]
	at org.apache.pulsar.broker.transaction.buffer.impl.TableView.wait(TableView.java:96) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at org.apache.pulsar.broker.transaction.buffer.impl.TableView.readLatest(TableView.java:63) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	at org.apache.pulsar.broker.transaction.buffer.impl.SingleSnapshotAbortedTxnProcessorImpl.lambda$recoverFromSnapshot$1(SingleSnapshotAbortedTxnProcessorImpl.java:93) ~[org.apache.pulsar-pulsar-broker-4.0.5.jar:4.0.5]
	... 4 more
2025-06-09T09:14:12,992+0000 [pulsar-transaction-executor-17-1] INFO  org.apache.bookkeeper.mledger.impl.ManagedCursorImpl - [public/default/persistent/my-single-partitioned-topic-partition-0-my-sub] Rewind from 541:0 to 541:0

[Flaky Test] TestMessageSingleRouter #1376

Description

Metadata

Metadata

Assignees

Labels

Type

Projects

Milestone

Relationships

Development

Issue actions