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/07/31 13:59:16 UTC
[2/2] flink git commit: [FLINK-7300] Increase timeout in Kafka
end-to-end test
[FLINK-7300] Increase timeout in Kafka end-to-end test
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d578810b
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d578810b
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d578810b
Branch: refs/heads/master
Commit: d578810b45aaabe0e83a2064d7fa324981466b75
Parents: 3445efc
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Mon Jul 31 15:57:30 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Mon Jul 31 15:57:30 2017 +0200
----------------------------------------------------------------------
test-infra/end-to-end-test/test_streaming_kafka010.sh | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/d578810b/test-infra/end-to-end-test/test_streaming_kafka010.sh
----------------------------------------------------------------------
diff --git a/test-infra/end-to-end-test/test_streaming_kafka010.sh b/test-infra/end-to-end-test/test_streaming_kafka010.sh
index 638c34b..6f2d5c0 100755
--- a/test-infra/end-to-end-test/test_streaming_kafka010.sh
+++ b/test-infra/end-to-end-test/test_streaming_kafka010.sh
@@ -73,8 +73,8 @@ $FLINK_DIR/bin/flink run -d build-target/examples/streaming/Kafka010Example.jar
# send some data to Kafka
echo -e "hello\nwhats\nup" | $KAFKA_DIR/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-input
-# wait at most (roughly) 60 seconds until the results are there
-for i in {1..60}; do
+# wait at most (roughly) 5 minutes until the results are there
+for i in {1..300}; do
DATA_FROM_KAFKA=$($KAFKA_DIR/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test-output --from-beginning --timeout-ms 0 2> /dev/null)
# make sure we have actual newlines in the string, not "\n"