diff --git a/backend/src/main/java/io/dataease/service/spark/SparkCalc.java b/backend/src/main/java/io/dataease/service/spark/SparkCalc.java index 52668d7603..ba558edd75 100644 --- a/backend/src/main/java/io/dataease/service/spark/SparkCalc.java +++ b/backend/src/main/java/io/dataease/service/spark/SparkCalc.java @@ -25,6 +25,7 @@ import org.springframework.stereotype.Service; import scala.Tuple2; import javax.annotation.Resource; +import java.math.BigDecimal; import java.text.MessageFormat; import java.util.ArrayList; import java.util.Base64; @@ -80,7 +81,7 @@ public class SparkCalc { if (StringUtils.isEmpty(l)) { l = "0"; } - list.add(Long.valueOf(l)); + list.add(new BigDecimal(l)); } }); yAxis.forEach(y -> { @@ -91,7 +92,7 @@ public class SparkCalc { if (StringUtils.isEmpty(l)) { l = "0"; } - list.add(Long.valueOf(l)); + list.add(new BigDecimal(l)); } }); iterator.add(RowFactory.create(list.toArray()));