This is an automated email from the ASF dual-hosted git repository.
wanghailin pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 9781a6a38 [improve][connector-v2][clickhouse] Fix DoubleInjectFunction
(#3441)
9781a6a38 is described below
commit 9781a6a385d6229dbca617b8cdf83a75e599c715
Author: matesoul <[email protected]>
AuthorDate: Wed Nov 16 11:06:00 2022 +0800
[improve][connector-v2][clickhouse] Fix DoubleInjectFunction (#3441)
Co-authored-by: liusiyuan <>
---
.../seatunnel/clickhouse/sink/inject/DoubleInjectFunction.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 c416d110c..2454dcd97 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 class DoubleInjectFunction implements
ClickhouseFieldInjectFunction {
if (value instanceof BigDecimal) {
statement.setDouble(index, ((BigDecimal) value).doubleValue());
} else {
- statement.setDouble(index, (Double) value);
+ statement.setDouble(index, Double.parseDouble(value.toString()));
}
}