Skip to content

Commit 82c4d34

Browse files
committed
try correctly release all resources in kafka sink protobuf test
Signed-off-by: Bugen Zhao <[email protected]>
1 parent fa856f1 commit 82c4d34

File tree

1 file changed

+4
-7
lines changed

1 file changed

+4
-7
lines changed

e2e_test/sink/kafka/protobuf.slt

+4-7
Original file line numberDiff line numberDiff line change
@@ -150,16 +150,13 @@ format plain encode protobuf (
150150
message = 'recursive.AllTypes');
151151

152152
statement ok
153-
drop sink sink_csr_nested;
153+
drop table from_kafka cascade;
154154

155155
statement ok
156-
drop sink sink_csr_trivial;
156+
drop table from_kafka_csr_trivial cascade;
157157

158158
statement ok
159-
drop sink sink0;
159+
drop table from_kafka_csr_nested cascade;
160160

161161
statement ok
162-
drop table into_kafka;
163-
164-
statement ok
165-
drop table from_kafka;
162+
drop table into_kafka cascade;

0 commit comments

Comments
 (0)