[hotfix][kafka] Remove unsued field in FlinkKafkaProducer011
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5058c3f6 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5058c3f6 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5058c3f6 Branch: refs/heads/master Commit: 5058c3f6c4e8f90e2bb40f9c2d2bf171ecf51ae6 Parents: 425ffe2 Author: Piotr Nowojski <[email protected]> Authored: Fri Oct 27 15:14:58 2017 +0200 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Thu Nov 2 12:43:20 2017 +0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaProducer011.java | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5058c3f6/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java index a69c730..f349df3 100644 --- a/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java +++ b/flink-connectors/flink-connector-kafka-0.11/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaProducer011.java @@ -46,7 +46,6 @@ import org.apache.flink.streaming.util.serialization.SerializationSchema; import org.apache.flink.util.ExceptionUtils; import org.apache.flink.util.NetUtils; import org.apache.flink.util.Preconditions; -import org.apache.flink.util.SerializableObject; import org.apache.flink.shaded.guava18.com.google.common.collect.Lists; @@ -254,9 +253,6 @@ public class FlinkKafkaProducer011<IN> @Nullable private transient volatile Exception asyncException; - /** Lock for accessing the pending records. */ - private final SerializableObject pendingRecordsLock = new SerializableObject(); - /** Number of unacknowledged records. */ private final AtomicLong pendingRecords = new AtomicLong();
