(seatunnel) branch dev updated: [Hotfix][Split] Fix split key not support BigInteger type

[gaojun2048]

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 5adf5d2b9a [Hotfix][Split] Fix split key not support BigInteger type
5adf5d2b9a is described below

commit 5adf5d2b9a163a7e8ae6a526ccbea9ae239c7091
Author: Eric <gaojun2...@gmail.com>
AuthorDate: Tue Dec 5 19:39:56 2023 +0800

    [Hotfix][Split] Fix split key not support BigInteger type
---
 .../seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java | 3 +++
 1 file changed, 3 insertions(+)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
index 957c929323..aa93d2d8a5 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java
@@ -33,6 +33,7 @@ import lombok.extern.slf4j.Slf4j;
 
 import java.io.Serializable;
 import java.math.BigDecimal;
+import java.math.BigInteger;
 import java.sql.Array;
 import java.sql.Date;
 import java.sql.PreparedStatement;
@@ -250,6 +251,8 @@ public class FixedChunkSplitter extends ChunkSplitter {
             return (BigDecimal) o;
         } else if (o instanceof Long) {
             return BigDecimal.valueOf((Long) o);
+        } else if (o instanceof BigInteger) {
+            return new BigDecimal((BigInteger) o);
         } else if (o instanceof Integer) {
             return BigDecimal.valueOf((Integer) o);
         } else if (o instanceof Double) {