diff --git a/e2e_test/source_inline/kafka/alter/kafka.slt b/e2e_test/source_inline/kafka/alter/add_column.slt similarity index 95% rename from e2e_test/source_inline/kafka/alter/kafka.slt rename to e2e_test/source_inline/kafka/alter/add_column.slt index d0a924c9ae6e..5ea9e4c22204 100644 --- a/e2e_test/source_inline/kafka/alter/kafka.slt +++ b/e2e_test/source_inline/kafka/alter/add_column.slt @@ -157,7 +157,7 @@ table description s1 NULL NULL query TT show create source s1; ---- -public.s1 CREATE SOURCE s1 (v1 INT, v2 CHARACTER VARYING, v3 INT) WITH (connector = 'kafka', topic = 'kafka_alter', properties.bootstrap.server = 'message_queue:29092', scan.startup.mode = 'earliest') FORMAT PLAIN ENCODE JSON +public.s1 CREATE SOURCE s1 (v1 INT, v2 CHARACTER VARYING, v3 INT) WITH (connector = 'kafka', properties.bootstrap.server = 'message_queue:29092', topic = 'kafka_alter', scan.startup.mode = 'earliest') FORMAT PLAIN ENCODE JSON system ok @@ -269,3 +269,9 @@ select * from t statement ok drop table t; + +statement ok +drop source s1 + +statement ok +drop source s2