diff --git a/ci/scripts/connector-node-integration-test.sh b/ci/scripts/connector-node-integration-test.sh
index 0ebdd35ea682a..519215584abb9 100755
--- a/ci/scripts/connector-node-integration-test.sh
+++ b/ci/scripts/connector-node-integration-test.sh
@@ -86,7 +86,7 @@ tar xf java-binding-integration-test.tar.zst bin
 
 echo "--- prepare integration tests"
 cd "${RISINGWAVE_ROOT}"/java/connector-node
-pip3 install grpcio grpcio-tools psycopg2 psycopg2-binary pyspark==3.3 black
+pip3 install --break-system-packages grpcio grpcio-tools psycopg2 psycopg2-binary pyspark==3.3 black
 cd python-client && bash gen-stub.sh && bash format-python.sh --check
 export PYTHONPATH=proto
 
diff --git a/ci/scripts/e2e-source-test.sh b/ci/scripts/e2e-source-test.sh
index 8e1ea0fa2b4b2..97e1040968604 100755
--- a/ci/scripts/e2e-source-test.sh
+++ b/ci/scripts/e2e-source-test.sh
@@ -152,7 +152,7 @@ risedev ci-kill
 
 echo "--- e2e, ci-kafka-plus-pubsub, kafka and pubsub source"
 RUST_LOG="info,risingwave_stream=info,risingwave_batch=info,risingwave_storage=info" \
-risedev ci-start ci-pubsub-kafka
+risedev ci-start ci-pubsub
 ./scripts/source/prepare_ci_kafka.sh
 cargo run --bin prepare_ci_pubsub
 risedev slt './e2e_test/source/basic/*.slt'