encode it as double

PeerDB-io · Feb 7, 2024 · 321fa73 · 321fa73
1 parent c3a753d
commit 321fa73
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/flow/model/qvalue/avro_converter.go b/flow/model/qvalue/avro_converter.go
@@ -273,7 +273,10 @@ func (c *QValueAvroConverter) ToAvroValue() (interface{}, error) {
 		}
 		return c.processNullableUnion("string", c.Value.Value)
 	case QValueKindFloat32:
-		return c.processNullableUnion("float", c.Value.Value)
+		if c.TargetDWH == QDWHTypeSnowflake || c.TargetDWH == QDWHTypeBigQuery {
+			return c.processNullableUnion("double", c.Value.Value)
+		}
+		return c.processNullableUnion("double", c.Value.Value)
 	case QValueKindFloat64:
 		if c.TargetDWH == QDWHTypeSnowflake || c.TargetDWH == QDWHTypeBigQuery {
 			if f32Val, ok := c.Value.Value.(float32); ok {