You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/11/02 10:00:06 UTC
[08/11] flink git commit: [hotfix][kafka] Remove unsued field in
FlinkKafkaProducer011
[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 <pi...@gmail.com>
Authored: Fri Oct 27 15:14:58 2017 +0200
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
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();