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()));
         }
     }
 

Reply via email to