Invalid Case expression. Schema for the default clause should be the same as schema for THEN clauses. Result scheme: Schema{INT32}. Schema for default expression is Schema{FLOAT64}

[eksantrik]

When I create a stream with the following single column it works:

CREATE STREAM CISCOCDRCMR_MERGE WITH (PARTITIONS=1) AS SELECT (CASE WHEN "CMR_PKID" IS NOT NULL AND "CMR_NUMBERPACKETSRECEIVED">0 THEN (100*"CMR_NUMBERPACKETSLOST") ELSE -1 END) AS CMR_PACKETLOSS_PERCENT FROM CISCOCDRCMR_ORIGLEG_MERGE;

But when I add a second column it gives me an error:

CREATE STREAM CISCOCDRCMR_MERGE WITH (PARTITIONS=1) AS SELECT (CASE WHEN "CMR_SCS" IS NULL THEN -1 ELSE "CMR_SCS" END) AS CMR_SCS,(CASE WHEN "CMR_PKID" IS NOT NULL AND "CMR_NUMBERPACKETSRECEIVED">0 THEN (100*"CMR_NUMBERPACKETSLOST") ELSE -1 END) AS CMR_PACKETLOSS_PERCENT FROM CISCOCDRCMR_ORIGLEG_MERGE;

Invalid Case expression. Schema for the default clause should be the same as schema for THEN clauses. Result scheme: Schema{INT32}. Schema for default expression is Schema{FLOAT64}

Is this the expected behavior? Do I need to CAST some variables to fix this?

[eksantrik]

I noticed that when I try to create the stream with a bunch of INTEGER fields and my WHEN clause for "CMR_PACKETLOSS_PERCENT", the stream is created. However, if I try to include a DOUBLE field such as CMR_SCS as above, the system throws an error.

[vezir]

I think, then and else part should contain the same type of number. Therefore if cmr_scs field is double then then field must be -1.0 instead of -1