From 8167519651b7c2669c813fb3aa48d3b299a2350b Mon Sep 17 00:00:00 2001 From: Bohan Zhang Date: Thu, 6 Jun 2024 17:52:34 +0800 Subject: [PATCH] test: fix pulsar test - expired credential (#17152) Signed-off-by: tabVersion --- e2e_test/source/pulsar/astra-streaming.py | 2 +- e2e_test/source/pulsar/pulsar.slt | 11 ++++++----- 2 files changed, 7 insertions(+), 6 deletions(-) diff --git a/e2e_test/source/pulsar/astra-streaming.py b/e2e_test/source/pulsar/astra-streaming.py index 299529e170232..b2e653ed5677b 100644 --- a/e2e_test/source/pulsar/astra-streaming.py +++ b/e2e_test/source/pulsar/astra-streaming.py @@ -20,7 +20,7 @@ def do_test(config): cur.execute(f'''CREATE TABLE t (v1 int, v2 varchar) WITH ( connector='pulsar', - topic='persistent://tenant0/default/topic0', + topic='persistent://meetup/default/ci-test', service.url='pulsar+ssl://pulsar-gcp-useast1.streaming.datastax.com:6651', auth.token='{config['ASTRA_STREAMING_TOKEN']}' ) diff --git a/e2e_test/source/pulsar/pulsar.slt b/e2e_test/source/pulsar/pulsar.slt index 2072dfb6f8449..29dc30c60994b 100644 --- a/e2e_test/source/pulsar/pulsar.slt +++ b/e2e_test/source/pulsar/pulsar.slt @@ -1,8 +1,9 @@ query IT nosort select * FROM t; ---- -1 name0 -2 name0 -6 name3 -0 name5 -5 name8 \ No newline at end of file +1 name1 +2 name2 +3 name3 +4 name4 +5 name5 +6 name6