[hotfix][kafka] Fix FlinkKafkaProducer011 logger
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/872c35e5 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/872c35e5 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/872c35e5 Branch: refs/heads/master Commit: 872c35e52fc3034da081239fca062e5889c14c8a Parents: 1c123e4 Author: Piotr Nowojski <[email protected]> Authored: Thu Oct 26 10:02:15 2017 +0200 Committer: Tzu-Li (Gordon) Tai <[email protected]> Committed: Thu Nov 2 12:43:20 2017 +0800 ---------------------------------------------------------------------- .../flink/streaming/connectors/kafka/FlinkKafkaProducer011.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/872c35e5/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 e83966c..6242a20 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 @@ -136,7 +136,7 @@ public class FlinkKafkaProducer011<IN> NONE } - private static final Logger LOG = LoggerFactory.getLogger(FlinkKafkaProducerBase.class); + private static final Logger LOG = LoggerFactory.getLogger(FlinkKafkaProducer011.class); private static final long serialVersionUID = 1L;
