flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tzuli...@apache.org
Subject [3/3] flink git commit: [FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions
Date Fri, 20 Jan 2017 15:35:47 GMT
[FLINK-5368] [kafka] Log msg if kafka topic doesn't have any partitions

This closes #3036.


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

Branch: refs/heads/master
Commit: f266e825557f4091094a866e6887f52ca54ff2d7
Parents: 640a149
Author: HungUnicorn <unicorn.banachi@gmail.com>
Authored: Mon Jan 9 16:48:24 2017 +0100
Committer: Tzu-Li (Gordon) Tai <tzulitai@apache.org>
Committed: Fri Jan 20 16:33:25 2017 +0100

----------------------------------------------------------------------
 .../flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java    | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/f266e825/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
index 29bb8e4..2b816c4 100644
--- a/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
+++ b/flink-connectors/flink-connector-kafka-0.9/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer09.java
@@ -208,6 +208,9 @@ public class FlinkKafkaConsumer09<T> extends FlinkKafkaConsumerBase<T>
{
 				if (partitionsForTopic != null) {
 					partitions.addAll(convertToFlinkKafkaTopicPartition(partitionsForTopic));
 				}
+				else{
+					LOG.info("Unable to retrieve any partitions for the requested topic: {}", topic);
+				}
 			}
 		}
 


Mime
View raw message