Fix send get raw schema request (apache#6650)

### Motivation fix clientCnx sendGetRawSchema remove get schema request
lukestephenson · Apr 8, 2020 · 4d29bc4 · 4d29bc4
1 parent a658791
commit 4d29bc4
Showing 1 changed file with 1 addition and 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
@@ -814,7 +814,7 @@ public CompletableFuture<CommandGetSchemaResponse> sendGetRawSchema(ByteBuf requ
             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());
             }
         });