From 15afce5b32968905972aaffd72b1f6deb126b99f Mon Sep 17 00:00:00 2001 From: zentol Date: Mon, 25 Jun 2018 22:19:02 +0200 Subject: [PATCH] [FLINK-9659][tests] Replace hard-coded sleeps --- .../test-scripts/test_streaming_bucketing.sh | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh b/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh index e87191699e7ab..19da468dd89a1 100755 --- a/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh +++ b/flink-end-to-end-tests/test-scripts/test_streaming_bucketing.sh @@ -45,7 +45,7 @@ JOB_ID=$($FLINK_DIR/bin/flink run -d -p 4 $TEST_PROGRAM_JAR -outputPath $TEST_DA wait_job_running ${JOB_ID} -sleep 40 +wait_num_checkpoints "${JOB_ID}" 5 echo "Killing TM" @@ -70,7 +70,7 @@ $FLINK_DIR/bin/taskmanager.sh start $FLINK_DIR/bin/taskmanager.sh start # the job should complete in under 60s because half of the work has been checkpointed -sleep 100 +wait_job_terminal_state "${JOB_ID}" "FINISHED" # get truncate information # e.g. "xxx xxx DEBUG xxx.BucketingSink - Writing valid-length file for xxx/out/result8/part-0-0 to specify valid length 74994"