diff --git a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java index c416d110cbb..2454dcd975b 100644 --- a/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java +++ b/seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java @@ -27,7 +27,7 @@ public void injectFields(PreparedStatement statement, int index, Object value) t if (value instanceof BigDecimal) { statement.setDouble(index, ((BigDecimal) value).doubleValue()); } else { - statement.setDouble(index, (Double) value); + statement.setDouble(index, Double.parseDouble(value.toString())); } }