fix

Signed-off-by: tabVersion <[email protected]>
risingwavelabs · Jun 3, 2024 · 981baf5 · 981baf5
1 parent 914bdc5
commit 981baf5
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/e2e_test/source_inline/kafka/avro/name_strategy.slt b/e2e_test/source_inline/kafka/avro/name_strategy.slt
@@ -38,9 +38,9 @@ FORMAT UPSERT ENCODE AVRO (schema.registry = '${RISEDEV_SCHEMA_REGISTRY_URL}');
 
 statement ok
 CREATE TABLE upsert_avro_json (
-  PRIMARY KEY("ID")
+  PRIMARY KEY("ID_KEY")
 )
-INCLUDE KEY AS "ID"
+INCLUDE KEY AS "ID_KEY"
 WITH (
   connector = 'kafka',
   properties.bootstrap.server = '${RISEDEV_KAFKA_BOOTSTRAP_SERVERS}',