(flink) 01/03: [hotfix][e2e] Fix naming of MAX_NUM_METRICS

[pn...@apache.org]

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

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

commit 7ae0a826ca54f9d402088adafc2ac439869d2aa6
Author: Piotr Nowojski <pi...@gmail.com>
AuthorDate: Tue Mar 5 13:40:00 2024 +0100

    [hotfix][e2e] Fix naming of MAX_NUM_METRICS
---
 flink-end-to-end-tests/test-scripts/common.sh | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/flink-end-to-end-tests/test-scripts/common.sh b/flink-end-to-end-tests/test-scripts/common.sh
index db09fdceb15..f4ee00b717a 100755
--- a/flink-end-to-end-tests/test-scripts/common.sh
+++ b/flink-end-to-end-tests/test-scripts/common.sh
@@ -741,7 +741,7 @@ function get_num_metric_samples {
 
 function wait_oper_metric_num_in_records {
     OPERATOR=$1
-    MAX_NUM_METRICS="${2:-200}"
+    MAX_NUM_RECORDS="${2:-200}"
     JOB_NAME="${3:-General purpose test job}"
     NUM_METRICS=$(get_num_metric_samples ${OPERATOR} '${JOB_NAME}')
     OLD_NUM_METRICS=${4:-${NUM_METRICS}}
@@ -758,12 +758,12 @@ function wait_oper_metric_num_in_records {
         NUM_RECORDS=0
       fi
 
-      if (( $NUM_RECORDS < $MAX_NUM_METRICS )); then
-        echo "Waiting for job to process up to ${MAX_NUM_METRICS} records, current progress: ${NUM_RECORDS} records ..."
+      if (( $NUM_RECORDS < $MAX_NUM_RECORDS )); then
+        echo "Waiting for job to process up to ${MAX_NUM_RECORDS} records, current progress: ${NUM_RECORDS} records ..."
         sleep 1
         ((i++))
         if ((i > timeout)); then
-            echo "A timeout occurred waiting for job to process up to ${MAX_NUM_METRICS} records"
+            echo "A timeout occurred waiting for job to process up to ${MAX_NUM_RECORDS} records"
             exit 1
         fi
       else