You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/10/26 10:27:30 UTC
flink git commit: [FLINK-7300] Demote ERROR to WARN on Commit Failure
in KafkaConsumer
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 <al...@gmail.com>
Authored: Thu Oct 26 12:26:16 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
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();
}
};