Skip to content

Commit 25038bb

Browse files
committed
[feat-1579][core] oracle的数据为MONEY NUMBER(19, 4)类型,读入到flinkStreamsql后,变成BigInteger类型,导致该条数据解析失败。
1 parent ce250fb commit 25038bb

1 file changed

Lines changed: 2 additions & 0 deletions

File tree

core/src/main/java/com/dtstack/flink/sql/util/MathUtil.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -129,6 +129,8 @@ public static Double getDoubleVal(Object obj) {
129129
return ((BigDecimal) obj).doubleValue();
130130
} else if (obj instanceof Integer) {
131131
return ((Integer) obj).doubleValue();
132+
} else if (obj instanceof BigInteger) {
133+
return ((BigInteger) obj).doubleValue();
132134
}
133135

134136
throw new RuntimeException("not support type of " + obj.getClass() + " convert to Double.");

0 commit comments

Comments
 (0)