Fix wrongly report "3600 messages have timed-out" (apache#5477)

related issue apache#5349
vruc · Oct 28, 2019 · 0936068 · 0936068
1 parent 89e3f30
commit 0936068
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/UnAckedMessageTracker.java
@@ -129,7 +129,7 @@ public void run(Timeout t) throws Exception {
                 try {
                     ConcurrentOpenHashSet<MessageId> headPartition = timePartitions.removeFirst();
                     if (!headPartition.isEmpty()) {
-                        log.warn("[{}] {} messages have timed-out", consumerBase, timePartitions.size());
+                        log.warn("[{}] {} messages have timed-out", consumerBase, headPartition.size());
                         headPartition.forEach(messageId -> {
                             messageIds.add(messageId);
                             messageIdPartitionMap.remove(messageId);