This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris-spark-connector.git
The following commit(s) were added to refs/heads/master by this push:
new dfd868e [fix](connector) support read DECIMAL128 type (#290)
dfd868e is described below
commit dfd868ed9efc79b83dea9f3d294f7989ccf827ec
Author: North Lin <37775475+qg-...@users.noreply.github.com>
AuthorDate: Fri Mar 21 13:56:32 2025 +0800
[fix](connector) support read DECIMAL128 type (#290)
---
.../src/main/java/org/apache/doris/spark/client/read/RowBatch.java | 1 +
1 file changed, 1 insertion(+)
diff --git
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/RowBatch.java
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/RowBatch.java
index ba61d6a..86ad0cc 100644
---
a/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/RowBatch.java
+++
b/spark-doris-connector/spark-doris-connector-base/src/main/java/org/apache/doris/spark/client/read/RowBatch.java
@@ -348,6 +348,7 @@ public class RowBatch implements Serializable {
case "DECIMALV2":
case "DECIMAL32":
case "DECIMAL64":
+ case "DECIMAL128":
case "DECIMAL128I":
Preconditions.checkArgument(mt.equals(MinorType.DECIMAL),
typeMismatchMessage(colName, currentType, mt));
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
