fix

databendlabs · Dec 10, 2023 · bbb7a71 · bbb7a71
1 parent 7094810
commit bbb7a71
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/tests/suites/5_ee/05_stream/05_0000_ee_stream.sh b/tests/suites/5_ee/05_stream/05_0000_ee_stream.sh
@@ -12,9 +12,9 @@ echo "create stream default.test_s on table db_stream.t comment = 'test'" | $BEN
 echo "insert into db_stream.t values(2)" | $BENDSQL_CLIENT_CONNECT
 
 BASE_ROW_ID=$(echo "select _base_row_id from default.test_s" | $BENDSQL_CLIENT_CONNECT)
-echo "select change\$row_id=$BASE_ROW_ID from default.test_s" | $BENDSQL_CLIENT_CONNECT
+echo "select change\$row_id='$BASE_ROW_ID' from default.test_s" | $BENDSQL_CLIENT_CONNECT
 echo "optimize table db_stream.t compact" | $BENDSQL_CLIENT_CONNECT
-echo "select a, change\$action, change\$is_update, change\$row_id=$BASE_ROW_ID from default.test_s" | $BENDSQL_CLIENT_CONNECT
+echo "select a, change\$action, change\$is_update, change\$row_id='$BASE_ROW_ID' from default.test_s" | $BENDSQL_CLIENT_CONNECT
 
 echo "show streams like 'test_s'" | $BENDSQL_CLIENT_CONNECT | awk '{print $(NF-3), $(NF-2), $(NF-1), $NF}'
 echo "show full streams like 'test_s'" | $BENDSQL_CLIENT_CONNECT | awk '{print $(NF-6), $(NF-5), $(NF-4), $(NF-3), $(NF-2), $(NF-1), $NF}'