(seatunnel) branch dev updated: [Fix][Connector-V2] [Doris] Fix DECIMAL scale=0 conversion to avoid unintended MAX_SCALE (#9947)

[lidongdai]

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

lidongdai 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 cde147a859 [Fix][Connector-V2] [Doris] Fix DECIMAL scale=0 conversion 
to avoid unintended MAX_SCALE (#9947)
cde147a859 is described below

commit cde147a85947156d3504db3d3dc0902748d3dd90
Author: AzkabanWarden.Gf <niangao...@163.com>
AuthorDate: Sun Oct 19 23:37:40 2025 +0800

    [Fix][Connector-V2] [Doris] Fix DECIMAL scale=0 conversion to avoid 
unintended MAX_SCALE (#9947)
---
 .../connectors/doris/datatype/DorisTypeConverterV2.java   |  2 +-
 .../doris/datatype/DorisTypeConvertorV2Test.java          | 15 +++++++++++++++
 2 files changed, 16 insertions(+), 1 deletion(-)

diff --git 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConverterV2.java
 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConverterV2.java
index 9d9be808f1..feef2c3956 100644
--- 
a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConverterV2.java
+++ 
b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConverterV2.java
@@ -91,7 +91,7 @@ public class DorisTypeConverterV2 extends 
AbstractDorisTypeConverter {
                     p = typeDefine.getPrecision();
                 }
 
-                if (typeDefine.getScale() != null && typeDefine.getScale() > 
0) {
+                if (typeDefine.getScale() != null && typeDefine.getScale() >= 
0) {
                     scale = typeDefine.getScale();
                 }
                 DecimalType decimalType;
diff --git 
a/seatunnel-connectors-v2/connector-doris/src/test/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConvertorV2Test.java
 
b/seatunnel-connectors-v2/connector-doris/src/test/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConvertorV2Test.java
index 841f555bd1..7f2e8b995e 100644
--- 
a/seatunnel-connectors-v2/connector-doris/src/test/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConvertorV2Test.java
+++ 
b/seatunnel-connectors-v2/connector-doris/src/test/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConvertorV2Test.java
@@ -236,6 +236,21 @@ public class DorisTypeConvertorV2Test {
         Assertions.assertEquals(38L, column.getColumnLength());
         Assertions.assertEquals(2, column.getScale());
         Assertions.assertEquals(typeDefine.getColumnType(), 
column.getSourceType());
+
+        typeDefine =
+                BasicTypeDefine.builder()
+                        .name("test")
+                        .columnType("decimalv3(8,0)")
+                        .dataType("decimal")
+                        .precision(8L)
+                        .scale(0)
+                        .build();
+        column = DorisTypeConverterV2.INSTANCE.convert(typeDefine);
+        Assertions.assertEquals(typeDefine.getName(), column.getName());
+        Assertions.assertEquals(new DecimalType(8, 0), column.getDataType());
+        Assertions.assertEquals(8L, column.getColumnLength());
+        Assertions.assertEquals(0, column.getScale());
+        Assertions.assertEquals(typeDefine.getColumnType(), 
column.getSourceType());
     }
 
     @Test