Skip to content

Commit

Permalink
legacy row format syntax
Browse files Browse the repository at this point in the history
  • Loading branch information
xiangjinwu committed Feb 28, 2024
1 parent 87abf29 commit 6f88005
Showing 1 changed file with 19 additions and 19 deletions.
38 changes: 19 additions & 19 deletions e2e_test/source/basic/old_row_format_syntax/kafka.slt
Original file line number Diff line number Diff line change
Expand Up @@ -155,15 +155,15 @@ create table s8_no_schema_field (
properties.bootstrap.server = 'message_queue:29092'
) ROW FORMAT DEBEZIUM_JSON

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

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

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

query IITFFBTT
select id, sequence_id, name, score, avg_score, is_lasted, entrance_date, birthday, passed from s9;
----
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

query ITITT
select id, code, timestamp, xfas, contacts, sex from s10;
----
100 abc 1473305798 {"(0,200,10.0.0.1)","(1,400,10.0.0.2)"} ("{1xxx,2xxx}","{1xxx,2xxx}") MALE
# query IITFFBTT
# select id, sequence_id, name, score, avg_score, is_lasted, entrance_date, birthday, passed from s9;
# ----
# 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
#
# query ITITT
# select id, code, timestamp, xfas, contacts, sex from s10;
# ----
# 100 abc 1473305798 {"(0,200,10.0.0.1)","(1,400,10.0.0.2)"} ("{1xxx,2xxx}","{1xxx,2xxx}") MALE

query ITITT
select id, code, timestamp, xfas, contacts, sex from s11;
Expand Down Expand Up @@ -706,11 +706,11 @@ drop table s8
statement ok
drop table s8_no_schema_field

statement ok
drop table s9

statement ok
drop table s10
# statement ok
# drop table s9
#
# statement ok
# drop table s10

statement ok
drop table s11
Expand All @@ -733,8 +733,8 @@ drop table s16
statement ok
drop source s17

statement ok
drop source s18
# statement ok
# drop source s18

statement ok
drop table s20
Expand Down

0 comments on commit 6f88005

Please sign in to comment.