This is an automated email from the ASF dual-hosted git repository. penghui pushed a commit to branch branch-2.7 in repository https://gitbox.apache.org/repos/asf/pulsar.git
commit e59c24f67d76b171e423a39a8115fd7ce066343f 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 287240c..9acee95 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 @@ -323,12 +323,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
