前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Apache Kylin 2.3 样例分析

Apache Kylin 2.3 样例分析

作者头像
程裕强
发布2022-05-06 20:40:02
3150
发布2022-05-06 20:40:02
举报
文章被收录于专栏:大数据学习笔记

网上没有找到Apache Kylin 2.3相关的样子,只好参考Apache Kylin 1.x 相关例子,但是运行报错。只好自己慢慢排查,下面做个记录。

代码语言:javascript
复制
select sum(price) as total_price  from kylin_sales ks
where ks.part_dt between '2013-12-01' and '2013-12-31'
这里写图片描述
这里写图片描述
代码语言:javascript
复制
select sum(price) as total_price  from kylin_sales ks
where ks.part_dt between '2013-12-01' and '2013-12-31' and ks.region = 'Shanghai'

错误信息

代码语言:javascript
复制
From line 2, column 63 to line 2, column 68: Column 'REGION' not found in table 'KS' while executing SQL: "select sum(price) as total_price from kylin_sales ks where ks.part_dt between '2013-12-01' and '2013-12-31' and ks.region = 'Shanghai'"

查看日志

代码语言:javascript
复制
[root@node1 logs]# vi kylin.log
代码语言:javascript
复制
Message: From line 2, column 81 to line 2, column 86: Column 'REGION' not found in table 'KYLIN_SALES'
while executing SQL: "select sum(price) as total_price  from kylin_sales  where kylin_sales.part_dt between '2013-12-01' and '2013-12-31' and kylin_sales.region = 'Shanghai' LIMIT 50000"
==========================[QUERY]===============================

2018-05-31 09:17:44,366 ERROR [http-bio-7070-exec-1] controller.BasicController:61 :
org.apache.kylin.rest.exception.InternalErrorException: From line 2, column 81 to line 2, column 86: Column 'REGION' not found in table 'KYLIN_SALES'
while executing SQL: "select sum(price) as total_price  from kylin_sales  where kylin_sales.part_dt between '2013-12-01' and '2013-12-31' and kylin_sales.region = 'Shanghai' LIMIT 50000"
        at org.apache.kylin.rest.service.QueryService.doQueryWithCache(QueryService.java:474)
        at org.apache.kylin.rest.service.QueryService.doQueryWithCache(QueryService.java:390)
        at org.apache.kylin.rest.controller.QueryController.query(QueryController.java:86)
        at sun.reflect.GeneratedMethodAccessor178.invoke(Unknown Source)
        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
        at java.lang.reflect.Method.invoke(Method.java:498)
        at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205)
        at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133)
        at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)
        at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967)
        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:901)
        at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)

通过日志分析可知,kylin_sales数据表不存在region字段。 查看表结构,确实没有region字段,已经更名为ops_region

代码语言:javascript
复制
hive> desc  kylin_sales ;
OK
trans_id                bigint                                      
part_dt                 date                    Order Date          
lstg_format_name        string                  Order Transaction Type
leaf_categ_id           bigint                  Category ID         
lstg_site_id            int                     Site ID             
slr_segment_cd          smallint                                    
price                   decimal(19,4)           Order Price         
item_count              bigint                  Number of Purchased Goods
seller_id               bigint                  Seller ID           
buyer_id                bigint                  Buyer ID            
ops_user_id             string                  System User ID      
ops_region              string                  System User Region  
Time taken: 1.693 seconds, Fetched: 12 row(s)
hive> 

重新执行

代码语言:javascript
复制
select sum(price) as total_price  from kylin_sales ks
where ks.part_dt between '2013-12-01' and '2013-12-31' and ks.ops_region = 'Shanghai'
这里写图片描述
这里写图片描述

其他例子

代码语言:javascript
复制
select count(distinct seller_id) as total_sellers from kylin_sales
这里写图片描述
这里写图片描述
代码语言:javascript
复制
select seller_id, sum(price) as total_price from kylin_sales 
group by seller_id order by sum(price) desc
这里写图片描述
这里写图片描述
代码语言:javascript
复制
select count(*) as order_amount from kylin_sales where lstg_site_id = 0
这里写图片描述
这里写图片描述
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2018-05-31,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
相关产品与服务
Elasticsearch Service
腾讯云 Elasticsearch Service(ES)是云端全托管海量数据检索分析服务,拥有高性能自研内核,集成X-Pack。ES 支持通过自治索引、存算分离、集群巡检等特性轻松管理集群,也支持免运维、自动弹性、按需使用的 Serverless 模式。使用 ES 您可以高效构建信息检索、日志分析、运维监控等服务,它独特的向量检索还可助您构建基于语义、图像的AI深度应用。
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档