This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a commit to branch cron-master-e2e
in repository https://gitbox.apache.org/repos/asf/flink.git
commit a7f31375d5318aeef1f5958242272141b74117f1
Author: Timo Walther <twal...@apache.org>
AuthorDate: Wed Nov 7 09:41:52 2018 +0100
[hotfix] Add missing end-to-end tests
---
splits/split_checkpoints.sh | 9 ++++++---
splits/split_misc.sh | 10 ++++++++++
2 files changed, 16 insertions(+), 3 deletions(-)
diff --git a/splits/split_checkpoints.sh b/splits/split_checkpoints.sh
index 930b5a4..5dfe7e3 100755
--- a/splits/split_checkpoints.sh
+++ b/splits/split_checkpoints.sh
@@ -49,9 +49,12 @@ run_test "Resuming Savepoint (file, async, scale up)
end-to-end test" "$END_TO_E
run_test "Resuming Savepoint (file, sync, scale up) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 file false"
run_test "Resuming Savepoint (file, async, scale down) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file true"
run_test "Resuming Savepoint (file, sync, scale down) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 file false"
-run_test "Resuming Savepoint (rocks, no parallelism change) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2 rocks"
-run_test "Resuming Savepoint (rocks, scale up) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks"
-run_test "Resuming Savepoint (rocks, scale down) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks"
+run_test "Resuming Savepoint (rocks, no parallelism change, heap timers)
end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
rocks false heap"
+run_test "Resuming Savepoint (rocks, scale up, heap timers) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false heap"
+run_test "Resuming Savepoint (rocks, scale down, heap timers) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false heap"
+run_test "Resuming Savepoint (rocks, no parallelism change, rocks timers)
end-to-end test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 2
rocks false rocks"
+run_test "Resuming Savepoint (rocks, scale up, rocks timers) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 2 4 rocks false rocks"
+run_test "Resuming Savepoint (rocks, scale down, rocks timers) end-to-end
test" "$END_TO_END_DIR/test-scripts/test_resume_savepoint.sh 4 2 rocks false
rocks"
run_test "Resuming Externalized Checkpoint (file, async, no parallelism
change) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file
true true"
run_test "Resuming Externalized Checkpoint (file, sync, no parallelism change)
end-to-end test"
"$END_TO_END_DIR/test-scripts/test_resume_externalized_checkpoints.sh 2 2 file
false true"
diff --git a/splits/split_misc.sh b/splits/split_misc.sh
index 8050364..a9ef821 100755
--- a/splits/split_misc.sh
+++ b/splits/split_misc.sh
@@ -43,12 +43,16 @@ echo "Flink distribution directory: $FLINK_DIR"
# run_test "<description>" "$END_TO_END_DIR/test-scripts/<script_name>"
+run_test "Flink CLI end-to-end test" "$END_TO_END_DIR/test-scripts/test_cli.sh"
+
run_test "Queryable state (rocksdb) end-to-end test"
"$END_TO_END_DIR/test-scripts/test_queryable_state.sh rocksdb"
run_test "Queryable state (rocksdb) with TM restart end-to-end test"
"$END_TO_END_DIR/test-scripts/test_queryable_state_restart_tm.sh"
"skip_check_exceptions"
run_test "DataSet allround end-to-end test"
"$END_TO_END_DIR/test-scripts/test_batch_allround.sh"
run_test "Streaming SQL end-to-end test"
"$END_TO_END_DIR/test-scripts/test_streaming_sql.sh" "skip_check_exceptions"
run_test "Streaming bucketing end-to-end test"
"$END_TO_END_DIR/test-scripts/test_streaming_bucketing.sh"
"skip_check_exceptions"
+run_test "Streaming File Sink end-to-end test"
"$END_TO_END_DIR/test-scripts/test_streaming_file_sink.sh"
"skip_check_exceptions"
+run_test "Streaming File Sink s3 end-to-end test"
"$END_TO_END_DIR/test-scripts/test_streaming_file_sink.sh s3"
"skip_check_exceptions"
run_test "Stateful stream job upgrade end-to-end test"
"$END_TO_END_DIR/test-scripts/test_stateful_stream_job_upgrade.sh 2 4"
run_test "Elasticsearch (v1.7.1) sink end-to-end test"
"$END_TO_END_DIR/test-scripts/test_streaming_elasticsearch.sh 1
https://download.elastic.co/elasticsearch/elasticsearch/elasticsearch-1.7.1.tar.gz";
@@ -66,5 +70,11 @@ run_test "State TTL RocksDb backend end-to-end test"
"$END_TO_END_DIR/test-scrip
run_test "Run kubernetes test"
"$END_TO_END_DIR/test-scripts/test_kubernetes_embedded_job.sh"
+run_test "SQL Client end-to-end test"
"$END_TO_END_DIR/test-scripts/test_sql_client.sh"
+
+run_test "Heavy deployment end-to-end test"
"$END_TO_END_DIR/test-scripts/test_heavy_deployment.sh"
+
+run_test "ConnectedComponents iterations with high parallelism end-to-end
test" "$END_TO_END_DIR/test-scripts/test_high_parallelism_iterations.sh 25"
+
printf "\n[PASS] All tests passed\n"
exit 0
