Skip to content

Commit f00df0e

Browse files
committed
Merge branch 'revert-0e23e50c' into '1.5_v3.6.0'
Revert "Merge branch '1.5_3.6.0_bigunsigned' into '1.5_v3.6.0'" This reverts merge request !44 See merge request !45
2 parents 0e23e50 + 6db6e3b commit f00df0e

File tree

2 files changed

+0
-3
lines changed

2 files changed

+0
-3
lines changed

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/util/MathUtil.java

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -48,8 +48,6 @@ public static Long getLongVal(Object obj) {
4848
return Long.valueOf(obj.toString());
4949
} else if (obj instanceof BigDecimal) {
5050
return ((BigDecimal) obj).longValue();
51-
} else if (obj instanceof BigInteger) {
52-
return ((BigInteger) obj).longValue();
5351
}
5452

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

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/util/SwitchUtil.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,6 @@ public static Object getTarget(Object obj, String targetType) {
4242
return MathUtil.getIntegerVal(obj);
4343

4444
case "bigint":
45-
case "bigintunsigned":
4645
case "intunsigned":
4746
case "integerunsigned":
4847
return MathUtil.getLongVal(obj);

0 commit comments

Comments
 (0)