Skip to content

Commit 13e7efa

Browse files
fix LedgerHandle ensembleChangeCounter not used. (#4103)
### Motivation fix #4096 ensemble change counter not inc when ensemble change . ### Changes inc counter when ensemble change.
1 parent 62ea072 commit 13e7efa

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

bookkeeper-server/src/main/java/org/apache/bookkeeper/client/LedgerHandle.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1913,6 +1913,7 @@ void handleBookieFailure(final Map<Integer, BookieId> failedBookies) {
19131913

19141914
void ensembleChangeLoop(List<BookieId> origEnsemble, Map<Integer, BookieId> failedBookies) {
19151915
int ensembleChangeId = numEnsembleChanges.incrementAndGet();
1916+
ensembleChangeCounter.inc();
19161917
String logContext = String.format("[EnsembleChange(ledger:%d, change-id:%010d)]", ledgerId, ensembleChangeId);
19171918

19181919
// when the ensemble changes are too frequent, close handle

0 commit comments

Comments
 (0)