fix

Signed-off-by: xxchan <[email protected]>

e2e_test/nexmark/create_sources_kafka.slt.part

@@ -34,7 +34,7 @@ CREATE SOURCE auction (
 ) FORMAT PLAIN ENCODE JSON;
 
 statement ok
-CREATE TABLE bid (
+CREATE SOURCE bid (
     "auction" BIGINT,
     "bidder" BIGINT,
     "price" BIGINT,
@@ -46,84 +46,3 @@ CREATE TABLE bid (
     ${RISEDEV_KAFKA_WITH_OPTIONS_COMMON},
     topic = 'nexmark-bid'
 ) FORMAT PLAIN ENCODE JSON;
-
-
-# statement ok
-# CREATE SOURCE nexmark (
-#   event_type BIGINT,
-#   person STRUCT<"id" BIGINT,
-#                 "name" VARCHAR,
-#                 "email_address" VARCHAR,
-#                 "credit_card" VARCHAR,
-#                 "city" VARCHAR,
-#                 "state" VARCHAR,
-#                 "date_time" TIMESTAMP,
-#                 "extra" VARCHAR>,
-#   auction STRUCT<"id" BIGINT,
-#                  "item_name" VARCHAR,
-#                  "description" VARCHAR,
-#                  "initial_bid" BIGINT,
-#                  "reserve" BIGINT,
-#                  "date_time" TIMESTAMP,
-#                  "expires" TIMESTAMP,
-#                  "seller" BIGINT,
-#                  "category" BIGINT,
-#                  "extra" VARCHAR>,
-#   bid STRUCT<"auction" BIGINT,
-#              "bidder" BIGINT,
-#              "price" BIGINT,
-#              "channel" VARCHAR,
-#              "url" VARCHAR,
-#              "date_time" TIMESTAMP,
-#              "extra" VARCHAR>,
-#   date_time TIMESTAMP AS
-#     CASE
-#         WHEN event_type = 0 THEN (person).date_time
-#         WHEN event_type = 1 THEN (auction).date_time
-#         ELSE (bid).date_time
-#     END,
-#   WATERMARK FOR date_time AS date_time - INTERVAL '4' SECOND
-# ) WITH (
-#     ${RISEDEV_KAFKA_WITH_OPTIONS_COMMON},
-#     topic = 'nexmark-events'
-# ) FORMAT PLAIN ENCODE JSON;
-
-# statement ok
-# CREATE VIEW PERSON AS
-# SELECT (person).id,
-#        (person).name,
-#        (person).email_address,
-#        (person).credit_card,
-#        (person).city,
-#        (person).state,
-#        date_time,
-#        (person).extra
-# FROM nexmark
-# WHERE event_type = 0;
-
-# statement ok
-# CREATE VIEW AUCTION AS
-# SELECT (auction).id,
-#        (auction).item_name,
-#        (auction).description,
-#        (auction).initial_bid,
-#        date_time,
-#        (auction).reserve,
-#        (auction).expires,
-#        (auction).seller,
-#        (auction).category,
-#        (auction).extra
-# FROM nexmark
-# WHERE event_type = 1;
-
-# statement ok
-# CREATE VIEW BID AS
-# SELECT (bid).auction,
-#        (bid).bidder,
-#        (bid).price,
-#        (bid).channel,
-#        (bid).url,
-#        date_time,
-#        (bid).extra
-# FROM nexmark
-# WHERE event_type = 2;