This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.8 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit 81efccceec5e35c5a1d114cb58405d6d0d759ae4 Author: Rui Fu <[email protected]> AuthorDate: Thu Jul 29 07:16:15 2021 +0800 [pulsar-io] fix source stats exposing empty exceptions list (#11478) ### Motivation `pulsar-admin sources status` always have empty list of `latestSystemExceptions` and `latestSourceExceptions`. With some code digging, it turns out that it always returns `EMPTY_QUEUE`. (cherry picked from commit 2cefbcc38f01216a52d274c9793055ec819b8a21) --- .../apache/pulsar/functions/instance/stats/SourceStatsManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManager.java b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManager.java index f900625..f4e1da0 100644 --- a/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManager.java +++ b/pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/stats/SourceStatsManager.java @@ -351,12 +351,12 @@ public class SourceStatsManager extends ComponentStatsManager { @Override public EvictingQueue<InstanceCommunication.FunctionStatus.ExceptionInformation> getLatestSystemExceptions() { - return EMPTY_QUEUE; + return latestSystemExceptions; } @Override public EvictingQueue<InstanceCommunication.FunctionStatus.ExceptionInformation> getLatestSourceExceptions() { - return EMPTY_QUEUE; + return latestSourceExceptions; } @Override
