Repository: flink Updated Branches: refs/heads/master a9743eb68 -> dfbf83ff6
[FLINK-7300] Demote ERROR to WARN on Commit Failure in KafkaConsumer Committing the offset to Kafka can fail for various reasons, this is not always an error because Flink will keep processing just fine. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/dfbf83ff Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/dfbf83ff Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/dfbf83ff Branch: refs/heads/master Commit: dfbf83ff6356fae4948cc44a1d0908defaeca45f Parents: a9743eb Author: Aljoscha Krettek <[email protected]> Authored: Thu Oct 26 12:26:16 2017 +0200 Committer: Aljoscha Krettek <[email protected]> Committed: Thu Oct 26 12:26:16 2017 +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/dfbf83ff/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 3088b15..7cd1ae1 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 @@ -534,7 +534,7 @@ public abstract class FlinkKafkaConsumerBase<T> extends RichParallelSourceFuncti @Override public void onException(Throwable cause) { - LOG.error("Async Kafka commit failed.", cause); + LOG.warn("Async Kafka commit failed.", cause); failedCommits.inc(); } };
