From 4d9f74003be36a62ff8b5c99de472ceea2b40ba2 Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Wed, 7 Feb 2024 11:31:14 -0800 Subject: [PATCH] encode it as double --- flow/model/qvalue/avro_converter.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flow/model/qvalue/avro_converter.go b/flow/model/qvalue/avro_converter.go index cfb016994a..64c2eca185 100644 --- a/flow/model/qvalue/avro_converter.go +++ b/flow/model/qvalue/avro_converter.go @@ -273,6 +273,9 @@ func (c *QValueAvroConverter) ToAvroValue() (interface{}, error) { } return c.processNullableUnion("string", c.Value.Value) case QValueKindFloat32: + if c.TargetDWH == QDWHTypeSnowflake || c.TargetDWH == QDWHTypeBigQuery { + return c.processNullableUnion("double", c.Value.Value) + } return c.processNullableUnion("float", c.Value.Value) case QValueKindFloat64: if c.TargetDWH == QDWHTypeSnowflake || c.TargetDWH == QDWHTypeBigQuery {