栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Hive round(num, 0)取整问题记录

Hive round(num, 0)取整问题记录

生产环境ELK记录的报错信息:

ERROR c.x.c.d.b.s.i.TableWarnServiceImpl - executeTableWarnJob error: 
java.lang.NumberFormatException: For input string: "57.97888386123681"
	at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
	at java.lang.Long.parseLong(Long.java:589)
	at java.lang.Long.parseLong(Long.java:631)
	at com.xy.cloudiview.datasetsubscript.business.service.impl.TableWarnServiceImpl.checkItem(TableWarnServiceImpl.java:180)

对应的报错代码片段:

private boolean checkItem(TableWarnParams params, Object result) {
    boolean bl = false;
    // 设置的阈值
    Long threshold = params.getCount();
    Long count = Long.parseLong(result.toString());
    switch (params.getWhere()) {
        case ">":
            if (count > threshold) {
                bl = true;
            }
        default:
            break;
    }
    return bl;
}

报错的SQL语句:

select round(afpi_loanlevel_total_cnt_his24mth_miss * 100, 0) as afpi_miss_58
from view_monitor_miss_rate 
order by list_day desc 
limit 1

将这个SQL拿到类似于ad hoc这种即时查询可视化平台查询得到的结果:

考虑到是线上应用,故而考虑将SQL取整,即使用impala提供的round(num, 0)函数,这个函数在可视化查询平台上面的执行结果如下:

但是,ELK仍然记录如下日志:

ERROR c.x.c.d.b.s.i.TableWarnServiceImpl - executeTableWarnJob error: 
java.lang.NumberFormatException: For input string: "58.0"
	at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
	at java.lang.Long.parseLong(Long.java:589)
	at java.lang.Long.parseLong(Long.java:631)
	at com.xy.cloudiview.datasetsubscript.business.service.impl.TableWarnServiceImpl.checkItem(TableWarnServiceImpl.java:180)

于是只好在本地测试环境尝试重现这个问题。
将报错SQL简化一下,替换到postman的requestBody里(省略其他非相关的json字段):

{
	"sqlTmp": "select 57.97888386123681 as a, 11 as b;"
}


可见查询得到的是一个BigDecimal类型的数据。

使用round(num, 0)函数

本地无法复现问题。

没有办法,最后的解决方法:

// 兼容round(num, 0)之后依然存在小数点的问题
Long count;
// 兼容round(num, 0)之后依然存在小数点的问题
if (result.toString().contains(".")) {
    count = Math.round(Double.parseDouble(result.toString()));
} else {
    count = Long.parseLong(result.toString());
}

附使用的hive-jdbc版本号:


    org.apache.hive
    hive-jdbc
    1.1.0-cdh5.7.1


    org.apache.hadoop
    hadoop-common
    2.6.0-cdh5.7.1

参考NumberFormatException

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/696294.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号