From 3a0c41023d7fcc89ac01dd3a7486b352b8d0b75d Mon Sep 17 00:00:00 2001
From: CharlesCheung96 <xiaoshuaizx@gmail.com>
Date: Sun, 22 Dec 2024 17:12:16 +0800
Subject: [PATCH] fix pulsar

---
 tests/integration_tests/ddl_with_exists/run.sh | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/tests/integration_tests/ddl_with_exists/run.sh b/tests/integration_tests/ddl_with_exists/run.sh
index 1cb0d43d6cd..176e05bc0e7 100755
--- a/tests/integration_tests/ddl_with_exists/run.sh
+++ b/tests/integration_tests/ddl_with_exists/run.sh
@@ -35,7 +35,7 @@ function run() {
 	case $SINK_TYPE in
 	kafka) run_kafka_consumer $WORK_DIR "kafka://127.0.0.1:9092/$TOPIC_NAME?protocol=open-protocol&partition-num=4&version=${KAFKA_VERSION}&max-message-bytes=10485760" ;;
 	storage) run_storage_consumer $WORK_DIR $SINK_URI "" "" ;;
-	pulsar) run_pulsar_consumer --upstream-uri $SINK_URI ;;
+	pulsar) run_pulsar_consumer $WORK_DIR $SINK_URI ;;
 	esac
 
 	run_sql "CREATE DATABASE ddl_with_exists"