[pulsar] branch master updated: remove duplicated code and un-used import (#8376)

[penghui]

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

penghui 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 5dcfdbe  remove duplicated code and un-used import (#8376)
5dcfdbe is described below

commit 5dcfdbe82fa0994fe5cc93d027df31b8f1153181
Author: Aloys <lofterzh...@gmail.com>
AuthorDate: Tue Oct 27 23:00:15 2020 +0800

    remove duplicated code and un-used import (#8376)
    
    ### Motivation
    
    remove duplicated code and un-used import
---
 .../src/main/java/org/apache/pulsar/broker/service/Producer.java      | 4 ----
 .../src/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 394430a..8c67015 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 class Producer {
             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 056b75a..fcd4015 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.protocol.schema.SchemaInfoUtil;
 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;