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

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new d8fd8ea  Get last entry is trying to read entry -1 (#7495)
d8fd8ea is described below

commit d8fd8eaaa2e2dcb93ac69d80981365048b76c0b2
Author: Matteo Merli <[email protected]>
AuthorDate: Fri Jul 10 10:41:30 2020 -0700

    Get last entry is trying to read entry -1 (#7495)
---
 .../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.

Reply via email to