diff --git a/flow/connectors/clickhouse/normalize.go b/flow/connectors/clickhouse/normalize.go index 2debe0f4d5..6da8281f00 100644 --- a/flow/connectors/clickhouse/normalize.go +++ b/flow/connectors/clickhouse/normalize.go @@ -82,6 +82,12 @@ func getColName(overrides map[string]string, name string) string { } func getClickhouseTypeForNumericColumn(column *protos.FieldDescription) string { + if column.TypeModifier == -1 { + // use default precision and scale when unset. + precision, scale := datatypes.ClickHouseNumericCompatibility{}.DefaultPrecisionAndScale() + return fmt.Sprintf("Decimal(%d, %d)", precision, scale) + } + rawPrecision, _ := datatypes.ParseNumericTypmod(column.TypeModifier) if rawPrecision > datatypes.PeerDBClickHouseMaxPrecision { return "String"