Skip to content

Commit

Permalink
[hotfix][tests] Reduce metric fetcher interval for e2e tests
Browse files Browse the repository at this point in the history
  • Loading branch information
zentol committed Jan 17, 2019
1 parent 41c4a35 commit 3d25080
Show file tree
Hide file tree
Showing 5 changed files with 6 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down
2 changes: 2 additions & 0 deletions flink-end-to-end-tests/test-scripts/test_stream_state_ttl.sh
Original file line number Diff line number Diff line change
Expand Up @@ -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

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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"
Expand Down

0 comments on commit 3d25080

Please sign in to comment.