flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzuli...@apache.org
Subject [04/11] flink git commit: [hotfix][kafka] Fix FlinkKafkaProducer011 logger
Date Thu, 02 Nov 2017 10:00:02 GMT
[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 <piotr.nowojski@gmail.com>
Authored: Thu Oct 26 10:02:15 2017 +0200
Committer: Tzu-Li (Gordon) Tai <tzulitai@apache.org>
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;
 


Mime
View raw message