[flink] branch master updated: [hotfix][tests] Reduce metric fetcher interval for e2e tests

[ch...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 3d25080  [hotfix][tests] Reduce metric fetcher interval for e2e tests
3d25080 is described below

commit 3d25080f278a24250db27ccf91798efb5419961e
Author: zentol <ch...@apache.org>
AuthorDate: Thu Jan 17 11:36:33 2019 +0100

    [hotfix][tests] Reduce metric fetcher interval for e2e tests
---
 .../test-scripts/test_resume_externalized_checkpoints.sh                | 1 +
 flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh            | 1 +
 flink-end-to-end-tests/test-scripts/test_stateful_stream_job_upgrade.sh | 1 +
 flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh            | 2 ++
 flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh         | 1 +
 5 files changed, 6 insertions(+)

diff --git a/flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh b/flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh
index 48d68c9..9b7fdae 100755
--- a/flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh
+++ b/flink-end-to-end-tests/test-scripts/test_resume_externalized_checkpoints.sh
@@ -38,6 +38,7 @@ else
 fi
 
 change_conf "taskmanager.numberOfTaskSlots" "1" "${NUM_SLOTS}"
+set_conf "metrics.fetcher.update-interval" "2000"
 setup_flink_slf4j_metric_reporter
 start_cluster
 
diff --git a/flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh b/flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh
index 3057486..c1b8cff 100755
--- a/flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh
+++ b/flink-end-to-end-tests/test-scripts/test_resume_savepoint.sh
@@ -60,6 +60,7 @@ change_conf "taskmanager.numberOfTaskSlots" "1" "${NUM_SLOTS}"
 if [ $STATE_BACKEND_ROCKS_TIMER_SERVICE_TYPE == 'rocks' ]; then
   set_conf "state.backend.rocksdb.timer-service.factory" "rocksdb"
 fi
+set_conf "metrics.fetcher.update-interval" "2000"
 
 setup_flink_slf4j_metric_reporter
 
diff --git a/flink-end-to-end-tests/test-scripts/test_stateful_stream_job_upgrade.sh b/flink-end-to-end-tests/test-scripts/test_stateful_stream_job_upgrade.sh
index c042368..1e53115 100755
--- a/flink-end-to-end-tests/test-scripts/test_stateful_stream_job_upgrade.sh
+++ b/flink-end-to-end-tests/test-scripts/test_stateful_stream_job_upgrade.sh
@@ -30,6 +30,7 @@ fi
 
 change_conf "taskmanager.numberOfTaskSlots" "1" "${NUM_SLOTS}"
 setup_flink_slf4j_metric_reporter
+set_conf "metrics.fetcher.update-interval" "2000"
 
 start_cluster
 
diff --git a/flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh b/flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh
index fb911f3..3dca45a 100755
--- a/flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh
+++ b/flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh
@@ -45,6 +45,8 @@ function test_cleanup {
 trap test_cleanup INT
 trap test_cleanup EXIT
 
+set_conf "metrics.fetcher.update-interval" "2000"
+
 start_cluster
 start_taskmanagers $PARALLELISM
 
diff --git a/flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh b/flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh
index 2756197..b8ca27b 100755
--- a/flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh
+++ b/flink-end-to-end-tests/test-scripts/test_streaming_file_sink.sh
@@ -24,6 +24,7 @@ source "$(dirname "$0")"/common_s3.sh
 
 s3_setup hadoop
 set_conf_ssl "mutual"
+set_conf "metrics.fetcher.update-interval" "2000"
 
 OUT=temp/test_streaming_file_sink-$(uuidgen)
 OUTPUT_PATH="$TEST_DATA_DIR/$OUT"