Skip to content
This repository has been archived by the owner on Jan 24, 2024. It is now read-only.

[bugfix][transactions] Prevent ConcurrentModificationException in getProducer() #1868

Merged
merged 1 commit into from May 31, 2023
Merged

[bugfix][transactions] Prevent ConcurrentModificationException in getProducer() #1868

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
4 changes: 2 additions & 2 deletions .../io/streamnative/pulsar/handlers/kop/coordinator/transaction/TransactionStateManager.java
View file
Open in desktop
Expand Up @@ -74,8 +74,8 @@ public class TransactionStateManager {
@VisibleForTesting
protected final Set<Integer> leavingPartitions = Sets.newHashSet();

private final Map<Integer, CompletableFuture<Producer<ByteBuffer>>> txnLogProducerMap = Maps.newHashMap();
private final Map<Integer, CompletableFuture<Reader<ByteBuffer>>> txnLogReaderMap = Maps.newHashMap();
private final Map<Integer, CompletableFuture<Producer<ByteBuffer>>> txnLogProducerMap = Maps.newConcurrentMap();
private final Map<Integer, CompletableFuture<Reader<ByteBuffer>>> txnLogReaderMap = Maps.newConcurrentMap();

// Transaction metadata cache indexed by assigned transaction topic partition ids
// Map <partitionId, <transactionId, TransactionMetadata>>
Expand Down