tillrohrmann closed pull request #7114: [BP-1.5][FLINK-10856] Find latest
completed checkpoint for resume from externalized checkpoint e2e test
URL: https://github.com/apache/flink/pull/7114
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/flink-end-to-end-tests/test-scripts/common.sh
b/flink-end-to-end-tests/test-scripts/common.sh
index 018e12d6df0..8b370582149 100644
--- a/flink-end-to-end-tests/test-scripts/common.sh
+++ b/flink-end-to-end-tests/test-scripts/common.sh
@@ -531,3 +531,10 @@ function clean_log_files {
rm ${FLINK_DIR}/log/*
echo "Deleted all files under ${FLINK_DIR}/log/"
}
+
+function find_latest_completed_checkpoint {
+ local checkpoint_root_directory=$1
+ # a completed checkpoint must contain the _metadata file
+ local checkpoint_meta_file=$(ls -d
${checkpoint_root_directory}/chk-[1-9]*/_metadata | sort -Vr | head -n1)
+ echo "$(dirname "${checkpoint_meta_file}")"
+}
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 e0b97d6f6a8..f406784b4c5 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
@@ -113,7 +113,7 @@ else
fi
# take the latest checkpoint
-CHECKPOINT_PATH=$(ls -d $CHECKPOINT_DIR/$DATASTREAM_JOB/chk-[1-9]* | sort -Vr
| head -n1)
+CHECKPOINT_PATH=$(find_latest_completed_checkpoint
${CHECKPOINT_DIR}/${DATASTREAM_JOB})
if [ -z $CHECKPOINT_PATH ]; then
echo "Expected an externalized checkpoint to be present, but none exists."
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
With regards,
Apache Git Services
