flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [FLINK-3663] [kafka] Fix logPartitionInfo log statement
Date Thu, 24 Mar 2016 10:59:19 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.0 5357ebe03 -> 085f7b211


[FLINK-3663] [kafka] Fix logPartitionInfo log statement

This closes #1835.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/085f7b21
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/085f7b21
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/085f7b21

Branch: refs/heads/release-1.0
Commit: 085f7b211925c204eb10546b36a6958105e6b273
Parents: 5357ebe
Author: Niels Zeilemaker <nielszeilemaker@godatadriven.com>
Authored: Wed Mar 23 16:40:25 2016 +0100
Committer: Ufuk Celebi <uce@apache.org>
Committed: Thu Mar 24 11:59:02 2016 +0100

----------------------------------------------------------------------
 .../flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/085f7b21/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
----------------------------------------------------------------------
diff --git a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
index 51067d6..5f20f16 100644
--- a/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
+++ b/flink-streaming-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
@@ -217,7 +217,7 @@ public abstract class FlinkKafkaConsumerBase<T> extends RichParallelSourceFuncti
 		for (Map.Entry<String, Integer> e : countPerTopic.entrySet()) {
 			sb.append(e.getKey()).append(" (").append(e.getValue()).append("), ");
 		}
-		LOG.info("Consumer is going to read the following topics (with number of partitions): ",
sb.toString());
+		LOG.info("Consumer is going to read the following topics (with number of partitions): {}",
sb.toString());
 	}
 
 


Mime
View raw message