encode it as double

PeerDB-io · Feb 7, 2024 · 4d9f740 · 4d9f740
1 parent c3a753d
commit 4d9f740
Showing 1 changed file with 3 additions and 0 deletions.
diff --git 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 {