You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by rx...@apache.org on 2020/07/29 09:53:14 UTC

[pulsar] 08/10: Get last entry is trying to read entry -1 (#7495)

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

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

commit 9eee486de035f27de7b38670affc90698d7087fa
Author: Matteo Merli <mm...@apache.org>
AuthorDate: Fri Jul 10 10:41:30 2020 -0700

    Get last entry is trying to read entry -1 (#7495)
    
    
    (cherry picked from commit d8fd8eaaa2e2dcb93ac69d80981365048b76c0b2)
---
 .../src/main/java/org/apache/pulsar/broker/service/ServerCnx.java        | 1 +
 1 file changed, 1 insertion(+)

diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
index 3131a76..0b7499d 100644
--- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
+++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/ServerCnx.java
@@ -1480,6 +1480,7 @@ public class ServerCnx extends PulsarHandler {
                     .setPartition(partitionIndex).build();
 
             ctx.writeAndFlush(Commands.newGetLastMessageIdResponse(requestId, messageId));
+            return;
         }
 
         // For a valid position, we read the entry out and parse the batch size from its metadata.