Skip to content

Commit 4cf01e5

Browse files
committed
add tests for show create source
Signed-off-by: Bugen Zhao <[email protected]>
1 parent 8ee7b66 commit 4cf01e5

File tree

1 file changed

+10
-0
lines changed

1 file changed

+10
-0
lines changed

e2e_test/source_inline/kafka/protobuf/alter_source.slt

+10
Original file line numberDiff line numberDiff line change
@@ -23,6 +23,11 @@ FORMAT PLAIN ENCODE PROTOBUF(
2323
message = 'test.User'
2424
);
2525

26+
query T
27+
SELECT SUBSTRING(definition, 1, POSITION(' WITH' IN definition) - 1) FROM rw_sources WHERE name = 'src_user';
28+
----
29+
CREATE SOURCE src_user (id INT, name CHARACTER VARYING, address CHARACTER VARYING, city CHARACTER VARYING, gender CHARACTER VARYING, sc STRUCT<file_name CHARACTER VARYING>) INCLUDE timestamp
30+
2631
statement ok
2732
CREATE MATERIALIZED VIEW mv_user AS SELECT * FROM src_user;
2833

@@ -54,6 +59,11 @@ sleep 5s
5459
statement ok
5560
ALTER SOURCE src_user REFRESH SCHEMA;
5661

62+
query T
63+
SELECT SUBSTRING(definition, 1, POSITION(' WITH' IN definition) - 1) FROM rw_sources WHERE name = 'src_user';
64+
----
65+
CREATE SOURCE src_user (id INT, name CHARACTER VARYING, address CHARACTER VARYING, city CHARACTER VARYING, gender CHARACTER VARYING, sc STRUCT<file_name CHARACTER VARYING>, age INT) INCLUDE timestamp
66+
5767
statement ok
5868
CREATE MATERIALIZED VIEW mv_user_more AS SELECT * FROM src_user;
5969

0 commit comments

Comments
 (0)