Skip to content

Commit b3550c3

Browse files
committed
address comment
1 parent 2f57382 commit b3550c3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,7 @@ private void openWithMetadata(Versioned<LedgerMetadata> versionedMetadata) {
195195
}
196196

197197
// get the ledger metadata back
198-
final boolean needRecovery = !doRecovery || !metadata.isClosed();
198+
final boolean watchImmediately = !doRecovery || metadata.isClosed();
199199
try {
200200
// The ledger metadata may be modified even if it has been closed, because the auto-recovery component may
201201
// rewrite the ledger's metadata. Keep receiving a notification from ZK to avoid the following issue: an
@@ -209,7 +209,7 @@ private void openWithMetadata(Versioned<LedgerMetadata> versionedMetadata) {
209209
// Therefore, if a user needs to the feature that update metadata automatically, he will set
210210
// "keepUpdateMetadata" to "true",
211211
lh = new ReadOnlyLedgerHandle(bk.getClientCtx(), ledgerId, versionedMetadata, digestType,
212-
passwd, !needRecovery);
212+
passwd, watchImmediately);
213213
} catch (GeneralSecurityException e) {
214214
LOG.error("Security exception while opening ledger: " + ledgerId, e);
215215
openComplete(BKException.Code.DigestNotInitializedException, null);

0 commit comments

Comments
 (0)