From 1f00c066a57c627115d50ff679bf23c80944fce4 Mon Sep 17 00:00:00 2001 From: Gary Yao Date: Mon, 11 Nov 2019 15:15:28 +0100 Subject: [PATCH] [FLINK-14821][tests] Enable E2E test to pass with new DefaultScheduler Enable test_queryable_state_restart_tm ('Queryable state (rocksdb) with TM restart') to pass with new DefaultScheduler. This closes #10226. --- .../test-scripts/test_queryable_state_restart_tm.sh | 3 --- 1 file changed, 3 deletions(-) diff --git a/flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh b/flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh index 26a1a74ab9fc7..166d9e6aa3496 100755 --- a/flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh +++ b/flink-end-to-end-tests/test-scripts/test_queryable_state_restart_tm.sh @@ -91,9 +91,6 @@ function run_test() { latest_snapshot_count=$(cat $FLINK_DIR/log/*out* | grep "on snapshot" | tail -n 1 | awk '{print $4}') echo "Latest snapshot count was ${latest_snapshot_count}" - # wait until the TM loss was detected - wait_for_job_state_transition ${JOB_ID} "RESTARTING" "CREATED" - start_and_wait_for_tm wait_job_running ${JOB_ID}