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.