From 5dcfdbe82fa0994fe5cc93d027df31b8f1153181 Mon Sep 17 00:00:00 2001 From: Aloys Date: Tue, 27 Oct 2020 23:00:15 +0800 Subject: [PATCH] remove duplicated code and un-used import (#8376) ### Motivation remove duplicated code and un-used import --- .../main/java/org/apache/pulsar/broker/service/Producer.java | 4 ---- .../main/java/org/apache/pulsar/client/impl/ClientCnx.java | 1 - 2 files changed, 5 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java index 394430ace92d1..8c670153fc6de 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/Producer.java @@ -457,11 +457,7 @@ public void recycle() { entryId = -1L; batchSize = 0L; startTimeNs = -1L; - ledgerId = -1; - entryId = -1; - batchSize = 0; chunked = false; - startTimeNs = -1; recyclerHandle.recycle(this); } } 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 056b75a28c534..fcd40150cee37 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 @@ -91,7 +91,6 @@ import org.apache.pulsar.common.util.FutureUtil; import org.apache.pulsar.common.util.collections.ConcurrentLongHashMap; import org.apache.pulsar.client.impl.transaction.TransactionBufferHandler; -import org.apache.pulsar.transaction.common.exception.TransactionConflictException; import org.slf4j.Logger; import org.slf4j.LoggerFactory;