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:15 UTC
[1/2] flink git commit: [hotfix] Add more prominent logging around
end-to-end tests
Repository: flink
Updated Branches:
refs/heads/master 67e431dea -> d578810b4
[hotfix] Add more prominent logging around end-to-end tests
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/3445efc6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/3445efc6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/3445efc6
Branch: refs/heads/master
Commit: 3445efc6461f6b7cc7d7ffaf0d9ff80547172901
Parents: 67e431d
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Mon Jul 31 15:54:12 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Mon Jul 31 15:54:43 2017 +0200
----------------------------------------------------------------------
tools/travis_mvn_watchdog.sh | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/3445efc6/tools/travis_mvn_watchdog.sh
----------------------------------------------------------------------
diff --git a/tools/travis_mvn_watchdog.sh b/tools/travis_mvn_watchdog.sh
index b67ac3e..c36cecf 100755
--- a/tools/travis_mvn_watchdog.sh
+++ b/tools/travis_mvn_watchdog.sh
@@ -397,10 +397,19 @@ cd ../../
case $TEST in
(misc)
if [ $EXIT_CODE == 0 ]; then
- echo "Running automated end-to-end tests"
+ echo "\n=============================================================================="
+ echo "Running end-to-end tests"
+ echo "=============================================================================="
+ echo "\n=============================================================================="
+ echo "Running Wordcount end-to-end test"
+ echo "=============================================================================="
test-infra/end-to-end-test/test_batch_wordcount.sh build-target cluster
EXIT_CODE=$(($EXIT_CODE+$?))
+
+ echo "\n=============================================================================="
+ echo "Running Kafka end-to-end test"
+ echo "=============================================================================="
test-infra/end-to-end-test/test_streaming_kafka010.sh build-target cluster
EXIT_CODE=$(($EXIT_CODE+$?))
else
[2/2] flink git commit: [FLINK-7300] Increase timeout in Kafka
end-to-end test
Posted by al...@apache.org.
[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"