From 914bdc57e54b0fdce503647222e7b132408ea42c Mon Sep 17 00:00:00 2001 From: tabVersion Date: Mon, 3 Jun 2024 15:38:35 +0800 Subject: [PATCH] add include clause Signed-off-by: tabVersion --- e2e_test/source_inline/kafka/avro/name_strategy.slt | 1 + 1 file changed, 1 insertion(+) diff --git a/e2e_test/source_inline/kafka/avro/name_strategy.slt b/e2e_test/source_inline/kafka/avro/name_strategy.slt index 5c4ddc66e8522..fd40d24f17166 100644 --- a/e2e_test/source_inline/kafka/avro/name_strategy.slt +++ b/e2e_test/source_inline/kafka/avro/name_strategy.slt @@ -40,6 +40,7 @@ statement ok CREATE TABLE upsert_avro_json ( PRIMARY KEY("ID") ) +INCLUDE KEY AS "ID" WITH ( connector = 'kafka', properties.bootstrap.server = '${RISEDEV_KAFKA_BOOTSTRAP_SERVERS}',