Skip to content

Commit cf464cd

Browse files
committed
legacy row format syntax
1 parent 87abf29 commit cf464cd

File tree

1 file changed

+19
-19
lines changed
  • e2e_test/source/basic/old_row_format_syntax

1 file changed

+19
-19
lines changed

e2e_test/source/basic/old_row_format_syntax/kafka.slt

+19-19
Original file line numberDiff line numberDiff line change
@@ -155,15 +155,15 @@ create table s8_no_schema_field (
155155
properties.bootstrap.server = 'message_queue:29092'
156156
) ROW FORMAT DEBEZIUM_JSON
157157

158-
statement ok
158+
statement error without schema registry
159159
create table s9 with (
160160
connector = 'kafka',
161161
topic = 'avro_bin',
162162
properties.bootstrap.server = 'message_queue:29092',
163163
scan.startup.mode = 'earliest'
164164
) row format avro row schema location 'file:///risingwave/avro-simple-schema.avsc'
165165

166-
statement ok
166+
statement error without schema registry
167167
create table s10 with (
168168
connector = 'kafka',
169169
topic = 'avro_c_bin',
@@ -262,7 +262,7 @@ create source s17 with (
262262
scan.startup.mode = 'earliest'
263263
) row format protobuf message 'test.User' row schema location 'file:///risingwave/proto-complex-schema'
264264

265-
statement ok
265+
statement error without schema registry
266266
create source s18 with (
267267
connector = 'kafka',
268268
topic = 'avro_c_bin',
@@ -560,15 +560,15 @@ select id, first_name, last_name, email from s8_no_schema_field;
560560
1004 Anne1 Kretchmar [email protected]
561561
1005 add add2 add
562562

563-
query IITFFBTT
564-
select id, sequence_id, name, score, avg_score, is_lasted, entrance_date, birthday, passed from s9;
565-
----
566-
32 64 str_value 32 64 t 1970-01-01 1970-01-01 00:00:00+00:00 1 mon 1 day 00:00:01
567-
568-
query ITITT
569-
select id, code, timestamp, xfas, contacts, sex from s10;
570-
----
571-
100 abc 1473305798 {"(0,200,10.0.0.1)","(1,400,10.0.0.2)"} ("{1xxx,2xxx}","{1xxx,2xxx}") MALE
563+
# query IITFFBTT
564+
# select id, sequence_id, name, score, avg_score, is_lasted, entrance_date, birthday, passed from s9;
565+
# ----
566+
# 32 64 str_value 32 64 t 1970-01-01 1970-01-01 00:00:00+00:00 1 mon 1 day 00:00:01
567+
#
568+
# query ITITT
569+
# select id, code, timestamp, xfas, contacts, sex from s10;
570+
# ----
571+
# 100 abc 1473305798 {"(0,200,10.0.0.1)","(1,400,10.0.0.2)"} ("{1xxx,2xxx}","{1xxx,2xxx}") MALE
572572

573573
query ITITT
574574
select id, code, timestamp, xfas, contacts, sex from s11;
@@ -706,11 +706,11 @@ drop table s8
706706
statement ok
707707
drop table s8_no_schema_field
708708

709-
statement ok
710-
drop table s9
711-
712-
statement ok
713-
drop table s10
709+
# statement ok
710+
# drop table s9
711+
#
712+
# statement ok
713+
# drop table s10
714714

715715
statement ok
716716
drop table s11
@@ -733,8 +733,8 @@ drop table s16
733733
statement ok
734734
drop source s17
735735

736-
statement ok
737-
drop source s18
736+
# statement ok
737+
# drop source s18
738738

739739
statement ok
740740
drop table s20

0 commit comments

Comments
 (0)