You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by pe...@apache.org on 2026/10/18 20:45:55 UTC
(pulsar) branch master updated: [improve][meta] Log metadata store deletes at DEBUG (#26978)
This is an automated email from the ASF dual-hosted git repository.
codelipenghui pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/master by this push:
new 35cd2085bfae [improve][meta] Log metadata store deletes at DEBUG (#26978)
35cd2085bfae is described below
commit 35cd2085bfae7b43d245972a395d0ba402efde7c
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Sun Oct 18 13:45:47 2026 -0700
[improve][meta] Log metadata store deletes at DEBUG (#26978)
---
.../java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
index 03e334ff257e..f5ed70432186 100644
--- a/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
+++ b/pulsar-metadata/src/main/java/org/apache/pulsar/metadata/impl/AbstractMetadataStore.java
@@ -473,7 +473,7 @@ public abstract class AbstractMetadataStore implements MetadataStoreExtended, Co
@Override
public final CompletableFuture<Void> delete(String path, Optional<Long> expectedVersion, Set<Option> opts) {
- log.info().attr("path", path).attr("expectedVersion", expectedVersion).log("Deleting path");
+ log.debug().attr("path", path).attr("expectedVersion", expectedVersion).log("Deleting path");
if (isClosed()) {
return alreadyClosedFailedFuture();
}
@@ -518,7 +518,7 @@ public abstract class AbstractMetadataStore implements MetadataStoreExtended, Co
}
metadataCaches.forEach(c -> c.invalidate(path));
- log.info().attr("path", path).attr("expectedVersion", expectedVersion).log("Deleted path");
+ log.debug().attr("path", path).attr("expectedVersion", expectedVersion).log("Deleted path");
});
}