Valtor
New Contributor II

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';