You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/04/30 21:23:14 UTC
[13/15] flink git commit: [FLINK-9274] [kafka] Add thread name for
partition discovery
[FLINK-9274] [kafka] Add thread name for partition discovery
This closes #5942
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/fa63c335
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/fa63c335
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/fa63c335
Branch: refs/heads/master
Commit: fa63c3356b3fa89e549c058cbb6c6ecc19e61d8a
Parents: a8f4515
Author: Nico Kruber <ni...@data-artisans.com>
Authored: Mon Apr 30 14:22:40 2018 +0200
Committer: Stephan Ewen <se...@apache.org>
Committed: Mon Apr 30 21:28:54 2018 +0200
----------------------------------------------------------------------
.../flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/fa63c335/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
index 82ac2c3..cfb5b6d 100644
--- a/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
+++ b/flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumerBase.java
@@ -715,7 +715,7 @@ public abstract class FlinkKafkaConsumerBase<T> extends RichParallelSourceFuncti
}
}
}
- });
+ }, "Kafka Partition Discovery for " + getRuntimeContext().getTaskNameWithSubtasks());
discoveryLoopThread.start();
kafkaFetcher.runFetchLoop();