(pulsar) branch branch-3.0 updated: [fix][ml] Fix ML thread blocking issue in internalGetPartitionedStats API (#24167)

[lhotari]

This is an automated email from the ASF dual-hosted git repository.

lhotari pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-3.0 by this push:
     new 94f5e3b2f1b [fix][ml] Fix ML thread blocking issue in 
internalGetPartitionedStats API (#24167)
94f5e3b2f1b is described below

commit 94f5e3b2f1bab03ed43dd1c79891ded6503a7fb4
Author: 道君- Tao Jiuming <dao...@apache.org>
AuthorDate: Thu Apr 10 19:23:51 2025 +0800

    [fix][ml] Fix ML thread blocking issue in internalGetPartitionedStats API 
(#24167)
    
    (cherry picked from commit d9519d57f740c3f2e14f28d3588f5db70bc64165)
---
 .../org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java  | 7 ++++---
 1 file changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
index e6b918fbec4..b26828a700d 100644
--- 
a/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
+++ 
b/pulsar-broker/src/main/java/org/apache/pulsar/broker/admin/impl/PersistentTopicsBase.java
@@ -1564,9 +1564,10 @@ public class PersistentTopicsBase extends AdminResource {
                         .thenCompose(owned -> {
                             if (owned) {
                                 return getTopicReferenceAsync(partition)
-                                    .thenApply(ref ->
-                                        ref.getStats(getPreciseBacklog, 
subscriptionBacklogSize,
-                                            getEarliestTimeInBacklog));
+                                        .thenCompose(
+                                                ref -> 
ref.asyncGetStats(getPreciseBacklog, subscriptionBacklogSize,
+                                                        
getEarliestTimeInBacklog))
+                                        .thenApply(s -> (TopicStats) s);
                             } else {
                                 try {
                                     return 
pulsar().getAdminClient().topics().getStatsAsync(