Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
03-24-2023 01:38 PM
Per my testing, a string column used in a partition by clause (which happens to be followed by an integer column at creation) seems to be causing this issue.
So if you try putting it in second position, this seems to work.
CREATE TABLE IF NOT EXISTS TestEmit.Kafka_Emit_Log_Test
(
EnterpriseId INT NOT NULL,
Topic String NOT NULL,
Key String NOT NULL,
Value String NOT NULL
)
USING DELTA
PARTITIONED BY (Topic,EnterpriseId)
LOCATION '/mnt/test/emit/Kafka_Emit_Log_Test';