[FLINK-7300] Add new Kafka errors to ignored errors in end-to-end tests A new ERROR log message was added in FlinkKafkaConsumerBase that is emitted when asynchronous offset commit to the Kafka broker fails. We also ignore the accompanying exception, NoAvailableBrokersException.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/2ed74ca0 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/2ed74ca0 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/2ed74ca0 Branch: refs/heads/master Commit: 2ed74ca060ba64fefc7b53a23640d4854329f418 Parents: fd69dcc Author: Aljoscha Krettek <aljoscha.kret...@gmail.com> Authored: Mon Aug 7 20:22:23 2017 +0200 Committer: Aljoscha Krettek <aljoscha.kret...@gmail.com> Committed: Tue Aug 8 13:54:22 2017 +0200 ---------------------------------------------------------------------- test-infra/end-to-end-test/common.sh | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/2ed74ca0/test-infra/end-to-end-test/common.sh ---------------------------------------------------------------------- diff --git a/test-infra/end-to-end-test/common.sh b/test-infra/end-to-end-test/common.sh index e05f70f..9cf5e7b 100644 --- a/test-infra/end-to-end-test/common.sh +++ b/test-infra/end-to-end-test/common.sh @@ -65,12 +65,20 @@ function stop_cluster { $FLINK_DIR/bin/stop-cluster.sh fi - if grep -rv "GroupCoordinatorNotAvailableException" $FLINK_DIR/log | grep -v "RetriableCommitFailedException" | grep -iq "error"; then + if grep -rv "GroupCoordinatorNotAvailableException" $FLINK_DIR/log \ + | grep -v "RetriableCommitFailedException" \ + | grep -v "NoAvailableBrokersException" \ + | grep -v "Async Kafka commit failed" \ + | grep -iq "error"; then echo "Found error in log files:" cat $FLINK_DIR/log/* PASS="" fi - if grep -rv "GroupCoordinatorNotAvailableException" $FLINK_DIR/log | grep -v "RetriableCommitFailedException" | grep -iq "exception"; then + if grep -rv "GroupCoordinatorNotAvailableException" $FLINK_DIR/log \ + | grep -v "RetriableCommitFailedException" \ + | grep -v "NoAvailableBrokersException" \ + | grep -v "Async Kafka commit failed" \ + | grep -iq "exception"; then echo "Found exception in log files:" cat $FLINK_DIR/log/* PASS=""
