You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2016/07/13 09:27:48 UTC
flink git commit: [FLINK-4200] [Kafka Connector] Kafka consumers logs
the offset from which they restore
Repository: flink
Updated Branches:
refs/heads/master 6b7bb7614 -> 435ffd9c0
[FLINK-4200] [Kafka Connector] Kafka consumers logs the offset from which they restore
This closes #2230
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/435ffd9c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/435ffd9c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/435ffd9c
Branch: refs/heads/master
Commit: 435ffd9c06c435af382323963cd04a850e0148de
Parents: 6b7bb76
Author: Stefan Richter <s....@data-artisans.com>
Authored: Tue Jul 12 15:14:12 2016 +0200
Committer: zentol <ch...@apache.org>
Committed: Wed Jul 13 11:27:24 2016 +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/435ffd9c/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 ed5c72f..96a1e0d 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
@@ -322,7 +322,7 @@ public abstract class FlinkKafkaConsumerBase<T> extends RichParallelSourceFuncti
@Override
public void restoreState(HashMap<KafkaTopicPartition, Long> restoredOffsets) {
- LOG.info("Setting restore state in the FlinkKafkaConsumer");
+ LOG.info("Setting restore state in the FlinkKafkaConsumer: {}", restoredOffsets);
restoreToOffset = restoredOffsets;
}