[pulsar] branch master updated: Fix send get raw schema request (#6650)

[sijie]

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

sijie 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 4d29bc4  Fix send get raw schema request (#6650)
4d29bc4 is described below

commit 4d29bc4296c9ceaf4d843ed430e9e1e714bb5464
Author: congbo <39078850+congbobo...@users.noreply.github.com>
AuthorDate: Wed Apr 8 14:38:27 2020 +0800

    Fix send get raw schema request (#6650)
    
    ### Motivation
    fix clientCnx sendGetRawSchema remove get schema request
---
 .../src/main/java/org/apache/pulsar/client/impl/ClientCnx.java          | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java 
b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
index 3205608..b08a97c 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ClientCnx.java
@@ -814,7 +814,7 @@ public class ClientCnx extends PulsarHandler {
             if (!writeFuture.isSuccess()) {
                 log.warn("{} Failed to send GetSchema request to broker: {}", 
ctx.channel(),
                         writeFuture.cause().getMessage());
-                pendingGetLastMessageIdRequests.remove(requestId);
+                pendingGetSchemaRequests.remove(requestId);
                 future.completeExceptionally(writeFuture.cause());
             }
         });