首页 文章 精选 留言 我的

精选列表

搜索[实时查询],共10012篇文章
优秀的个人博客,低调大师

Hive查询失败:no LazyObject for VOID

线上一个ETLJob不能跑了,报异常,这里为了说明问题简化表结构: 1 2 3 4 hive> desc void_t; OK x int None z void None 而 1 select * from void_t 确实会抛出异常: 1 14 / 03 / 0201 : 28 : 58 ERROR CliDriver: Failed with exceptionjava.io.IOException:org.apache.hadoop.hive.ql.metadata.HiveException: Errorevaluating x 看到这个异常很疑惑,和x字段有什么关系呢,继续看详细日志: 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 java.io.IOException:org.apache.hadoop.hive.ql.metadata.HiveException: Error evaluating x atorg.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java: 150 ) atorg.apache.hadoop.hive.ql.Driver.getResults(Driver.java: 1412 ) at org.apache.hadoop.hive.cli.CliDriver.processLocalCmd(CliDriver.java: 271 ) atorg.apache.hadoop.hive.cli.CliDriver.processCmd(CliDriver.java: 216 ) atorg.apache.hadoop.hive.cli.CliDriver.processLine(CliDriver.java: 413 ) at org.apache.hadoop.hive.cli.CliDriver.run(CliDriver.java: 756 ) atorg.apache.hadoop.hive.cli.CliDriver.main(CliDriver.java: 614 ) atsun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) atsun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java: 39 ) atsun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java: 25 ) atjava.lang.reflect.Method.invoke(Method.java: 597 ) atorg.apache.hadoop.util.RunJar.main(RunJar.java: 208 ) Causedby: org.apache.hadoop.hive.ql.metadata.HiveException: Error evaluating x atorg.apache.hadoop.hive.ql.exec.SelectOperator.processOp(SelectOperator.java: 80 ) atorg.apache.hadoop.hive.ql.exec.Operator.process(Operator.java: 502 ) at org.apache.hadoop.hive.ql.exec.Operator.forward(Operator.java: 832 ) atorg.apache.hadoop.hive.ql.exec.TableScanOperator.processOp(TableScanOperator.java: 90 ) atorg.apache.hadoop.hive.ql.exec.Operator.process(Operator.java: 502 ) atorg.apache.hadoop.hive.ql.exec.FetchOperator.pushRow(FetchOperator.java: 490 ) atorg.apache.hadoop.hive.ql.exec.FetchTask.fetch(FetchTask.java: 136 ) ... 11 more Causedby: java.lang.RuntimeException: Internal error: no LazyObject for VOID atorg.apache.hadoop.hive.serde2.lazy.LazyFactory.createLazyPrimitiveClass(LazyFactory.java: 119 ) atorg.apache.hadoop.hive.serde2.lazy.LazyFactory.createLazyObject(LazyFactory.java: 155 ) at org.apache.hadoop.hive.serde2.lazy.LazyStruct.parse(LazyStruct.java: 108 ) atorg.apache.hadoop.hive.serde2.lazy.LazyStruct.getField(LazyStruct.java: 190 ) atorg.apache.hadoop.hive.serde2.lazy.objectinspector.LazySimpleStructObjectInspector.getStructFieldData(LazySimpleStructObjectInspector.java: 188 ) atorg.apache.hadoop.hive.serde2.objectinspector.DelegatedStructObjectInspector.getStructFieldData(DelegatedStructObjectInspector.java: 79 ) atorg.apache.hadoop.hive.ql.exec.ExprNodeColumnEvaluator.evaluate(ExprNodeColumnEvaluator.java: 98 ) atorg.apache.hadoop.hive.ql.exec.SelectOperator.processOp(SelectOperator.java: 76 ) 看到这个noLazyObject for VOID才知道原来问题出现在这里,也就是字段z上;查看ETL Job里的Query发现里面一个建表的语句用到了create table xxx as select null as z from xxx这样的方式,进而生成了一个VOID类型的字段,但是Hive本身却无法处理该字段,在jira里确实也有这么一个unresolved的Bug:HIVE-2615 Workaround也比较简单:1.先建表再insert select 2.在ctas时cast(null as <type>) z来强制指定类型. 本文转自MIKE老毕 51CTO博客,原文链接:http://blog.51cto.com/boylook/1365747,如需转载请自行联系原作者

优秀的个人博客,低调大师

elasticsearch 经纬度查询

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 curl-XPUT "http://localhost:9200/shop/" -d'{ "mappings" :{ "shop" :{ "properties" :{ "name" :{ "type" : "string" }, "location" :{ "type" : "geo_point" , //经纬度类型 "lat_lon" : true , "fielddata" :{ "format" : "compressed" , //压缩模式,节省内存 "precision" : "3m" } } } } } }'; curl-XPUThttp: //localhost:9200/shop/shop/1-d' { "name" : "北京" , "location" : "39.9047253699,116.4072154982" } '; curl-XPUThttp: //localhost:9200/shop/shop/2-d' { "name" : "顺义" , "location" : "40.1299127031,116.6569478577" } '; curl-XPUThttp: //localhost:9200/shop/shop/3-d' { "name" : "天津" , "location" : "39.0850853357,117.1993482089" } '; curl-XPUThttp: //localhost:9200/shop/shop/4-d' { "name" : "上海" , "location" : "31.2304324029,121.4737919321" } '; curl-XGET "http://localhost:9200/shop/shop/_search?pretty" -d'{ "query" :{ "filtered" :{ "filter" :{ "geo_distance" :{ "distance" : "28km" , "type" : "indexed" , "distance_type" : "sloppy_arc" , "location" :{ "lat" : 39.9682060617 , "lon" : 116.4107280170 } } } } }, "sort" :[ //按距离排序 { "_geo_distance" :{ "location" :{ "lat" : 39.9682060617 , "lon" : 116.4107280170 }, "order" : "asc" , "unit" : "km" , "distance_type" : "sloppy_arc" //推荐适应此模式plane不准,精度太差 } } ] }' 再举一个更加实际的例子 curl-XGET "http://localhost:9200/shop/shop/_search?pretty" -d'{ "query" :{ "function_score" :{ "query" :{ "bool" :{ "filter" :{ "geo_distance" :{ "distance" : "28km" , "type" : "indexed" , "distance_type" : "sloppy_arc" , "location" :{ "lat" : 39.9682060617 , "lon" : 116.4107280170 } } } } }, "functions" :[{ "script_score" :{ "script" :{ "inline" : "return0" } } },{ "gauss" :{ //按举例远近打分 "location" :{ "origin" : "39.9682060617,116.4107280170" , "scale" : "5km" , "offset" : "0" , "decay" : 0.5 } }, "weight" : "1" }], "score_mode" : "sum" , "boost_mode" : "replace" } } }' 此时你会看到北京的得分是 0.25 分,因为差 5 公里,衰减 0.5 ,北京距此坐标 7 公里,所以取值 0.25 . 2.3 版本的mapping可以写成 curl-XPUT "http://localhost:9200/shop/" -d'{ "mappings" :{ "shop" :{ "properties" :{ "name" :{ "type" : "string" }, "location" :{ "type" : "geo_point" , "lat_lon" : true , //倒排索引 "geohash" : true , "geohash_prefix" : true , "geohash_precision" : "50m" } } } } }'; 其实它还支持多个地址,例如 curl-XPUThttp: //localhost:9200/ext-shop/ext-shop/5-d' { "name" : "京津冀" , "location" :[[ 116.4072154982 , 39.9047253699 ],[ 116.6569478577 , 40.1299127031 ]]} '; 佩服ES的强大 本文转自whk66668888 51CTO博客,原文链接:http://blog.51cto.com/12597095/2048249

优秀的个人博客,低调大师

elasticsearch 关联查询对比

两种方式 嵌套和父子关联 Nested Nested docs are stored in the same Lucene block as each other, which helps read/query performance. Reading a nested doc is faster than the equivalent parent/child. Updating a single field in a nested document (parent or nested children) forces ES to reindex the entire nested document. This can be very expensive for large nested docs "Cross referencing" nested documents is impossible Best suited for data that does not change frequently Parent/Child Children are stored separately from the parent, but are routed to the same shard. So parent/children are slightly less performance on read/query than nested Parent/child mappings have a bit extra memory overhead, since ES maintains a "join" list in memory Updating a child doc does not affect the parent or any other children, which can potentially save a lot of indexing on large docs Sorting/scoring can be difficult with Parent/Child since the Has Child/Has Parent operations can be opaque at times 综上所述,两种方式均有利弊,官方建议,自己处理关联关系,减轻ES的压力。 本文转自whk66668888 51CTO博客,原文链接:http://blog.51cto.com/12597095/1904058

优秀的个人博客,低调大师

HBase查询优化——持续更新

Scan:setBatch,setCaching,setCacheBlocks public void setBatch(int batch) public void setCaching(int caching) public void setCacheBlocks(boolean cacheBlocks) setBatch:为设置获取记录的列个数,默认无限制,也就是返回所有的列 setCaching:每次从服务器端读取的行数,默认为配置文件中设置的值 <property> <name>hbase.client.scanner.caching</name> <value>100</value> </property> setCacheBlocks:是否缓存块,默认缓存,我们分内存,缓存和磁盘,三种方式,一般数据的读取为内存->缓存->磁盘,当为非热点数据,不需要缓存 设置示例: dataScan.setCacheBlocks(false);//禁用缓存块 dataScan.setBatch(19);//设置获取记录的列个数,默认都返回 dataScan.setCaching(500);//太大了占用内存,太少了rpc太多

优秀的个人博客,低调大师

实时计算助力1688打造「实时挑货」系统

一、背景 内容是一个电商app不可或缺的组成部分。越来越多的人会使用碎片时间浏览手机app的内容,包含导购的帖子、短视频、直播等。1688挑货业务,打造了基于买家和商家之间老买卖关系的内容场。让商家通过内容维系老客户,挖掘新客户。让买家能第一时间获取到关注商家的上新、优惠、直播等信息,为自己的采购等决策提供帮助。 从宏观的背景分析,挑货业务有以下几个特点: 基于1688的老买卖关系: 关注关系、客户会员关系、星标关系、分销关系 内容的产生源头是供应商,供应商在1688网站的各种行为,都可以转变成内容信息 内容的消费源头是供应商的老买家(与供应商有老买卖关系) 内容形式比较多样:帖子、营销活动、店铺上新、商家动态、直播、短视频等一系列商家产生的有效内容 内容产生形式:供应商的主动行为、供应商的被动行为 基于上面的业务特点,我们梳理下挑货整体的业务架

资源下载

更多资源
腾讯云软件源

腾讯云软件源

为解决软件依赖安装时官方源访问速度慢的问题,腾讯云为一些软件搭建了缓存服务。您可以通过使用腾讯云软件源站来提升依赖包的安装速度。为了方便用户自由搭建服务架构,目前腾讯云软件源站支持公网访问和内网访问。

Nacos

Nacos

Nacos /nɑ:kəʊs/ 是 Dynamic Naming and Configuration Service 的首字母简称,一个易于构建 AI Agent 应用的动态服务发现、配置管理和AI智能体管理平台。Nacos 致力于帮助您发现、配置和管理微服务及AI智能体应用。Nacos 提供了一组简单易用的特性集,帮助您快速实现动态服务发现、服务配置、服务元数据、流量管理。Nacos 帮助您更敏捷和容易地构建、交付和管理微服务平台。

Spring

Spring

Spring框架(Spring Framework)是由Rod Johnson于2002年提出的开源Java企业级应用框架,旨在通过使用JavaBean替代传统EJB实现方式降低企业级编程开发的复杂性。该框架基于简单性、可测试性和松耦合性设计理念,提供核心容器、应用上下文、数据访问集成等模块,支持整合Hibernate、Struts等第三方框架,其适用范围不仅限于服务器端开发,绝大多数Java应用均可从中受益。

Rocky Linux

Rocky Linux

Rocky Linux(中文名:洛基)是由Gregory Kurtzer于2020年12月发起的企业级Linux发行版,作为CentOS稳定版停止维护后与RHEL(Red Hat Enterprise Linux)完全兼容的开源替代方案,由社区拥有并管理,支持x86_64、aarch64等架构。其通过重新编译RHEL源代码提供长期稳定性,采用模块化包装和SELinux安全架构,默认包含GNOME桌面环境及XFS文件系统,支持十年生命周期更新。

用户登录
用户注册