Я создаю поток с типом данных Array. значение NULL приходит, поэтому обработайте это, я создаю другой поток поверх предыдущего потока и задаю регистр, как если бы его NULL ставил []. но это не работает.
Я пытался [], {}, [0], 0 в случаях.
CREATE STREAM stream1
(
id VARCHAR,
tags ARRAY<INT>,
feed_id VARCHAR,
status INT,
updated_at VARCHAR
)
WITH (kafka_topic='origin_topic', value_format='JSON');
Create Stream stream2 AS
select
id AS id,
case when tags is NULL THEN [] END ELSE tags END as tags,
case when feed_id is NULL THEN '0' ELSE feed_id END as feed_id,
case when status is NULL THEN 0 ELSE status END as status,
case when updated_at is NULL THEN '0' ELSE updated_at END as
updated_at
from stream1 PARTITION BY id;