This is an automated email from the ASF dual-hosted git repository.
rongr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 07bcab80f1 [test] add back quickstart streaming (#12231)
07bcab80f1 is described below
commit 07bcab80f1ba27b06ff50612d4189f3e9f5d2a2f
Author: Rong Rong <[email protected]>
AuthorDate: Sun Jan 7 20:31:28 2024 -0800
[test] add back quickstart streaming (#12231)
Co-authored-by: Rong Rong <[email protected]>
---
.github/workflows/scripts/.pinot_quickstart.sh | 71 +++++++++++++-------------
1 file changed, 35 insertions(+), 36 deletions(-)
diff --git a/.github/workflows/scripts/.pinot_quickstart.sh
b/.github/workflows/scripts/.pinot_quickstart.sh
index 20666265ac..ad81a97461 100755
--- a/.github/workflows/scripts/.pinot_quickstart.sh
+++ b/.github/workflows/scripts/.pinot_quickstart.sh
@@ -258,42 +258,41 @@ if [ "${PASS}" -eq 0 ]; then
fi
# Test quick-start-streaming
-# TODO: Streaming test is disabled because Meetup RSVP stream is retired. Find
a replacement and re-enable this test.
-#bin/quick-start-streaming.sh &
-#PID=$!
-#
-#PASS=0
-#RES_1=0
-#
-## Wait for 1 minute for table to be set up, then at most 5 minutes to reach
the desired state
-#sleep 60
-#for i in $(seq 1 150)
-#do
-# QUERY_RES=`curl -X POST --header 'Accept: application/json' -d
'{"sql":"select count(*) from meetupRsvp limit 1","trace":false}'
http://localhost:8000/query/sql`
-# if [ $? -eq 0 ]; then
-# COUNT_STAR_RES=`echo "${QUERY_RES}" | jq '.resultTable.rows[0][0]'`
-# if [[ "${COUNT_STAR_RES}" =~ ^[0-9]+$ ]] && [ "${COUNT_STAR_RES}" -gt 0
]; then
-# if [ "${RES_1}" -eq 0 ]; then
-# RES_1="${COUNT_STAR_RES}"
-# continue
-# elif [ "${COUNT_STAR_RES}" -gt "${RES_1}" ]; then
-# PASS=1
-# break
-# fi
-# fi
-# fi
-# sleep 2
-#done
-#
-#cleanup "${PID}"
-#if [ "${PASS}" -eq 0 ]; then
-# if [ "${RES_1}" -eq 0 ]; then
-# echo 'Streaming Quickstart test failed: Cannot get correct result for
count star query.'
-# exit 1
-# fi
-# echo 'Streaming Quickstart test failed: Cannot get incremental counts for
count star query.'
-# exit 1
-#fi
+bin/quick-start-streaming.sh &
+PID=$!
+
+PASS=0
+RES_1=0
+
+# Wait for 1 minute for table to be set up, then at most 5 minutes to reach
the desired state
+sleep 60
+for i in $(seq 1 150)
+do
+ QUERY_RES=`curl -X POST --header 'Accept: application/json' -d
'{"sql":"select count(*) from meetupRsvp limit 1","trace":false}'
http://localhost:8000/query/sql`
+ if [ $? -eq 0 ]; then
+ COUNT_STAR_RES=`echo "${QUERY_RES}" | jq '.resultTable.rows[0][0]'`
+ if [[ "${COUNT_STAR_RES}" =~ ^[0-9]+$ ]] && [ "${COUNT_STAR_RES}" -gt 0 ];
then
+ if [ "${RES_1}" -eq 0 ]; then
+ RES_1="${COUNT_STAR_RES}"
+ continue
+ elif [ "${COUNT_STAR_RES}" -gt "${RES_1}" ]; then
+ PASS=1
+ break
+ fi
+ fi
+ fi
+ sleep 2
+done
+
+cleanup "${PID}"
+if [ "${PASS}" -eq 0 ]; then
+ if [ "${RES_1}" -eq 0 ]; then
+ echo 'Streaming Quickstart test failed: Cannot get correct result for
count star query.'
+ exit 1
+ fi
+ echo 'Streaming Quickstart test failed: Cannot get incremental counts for
count star query.'
+ exit 1
+fi
# Test quick-start-hybrid
bin/quick-start-hybrid.sh &
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
