草庐IT

db_search

全部标签

hadoop - java.sql.SQLException : Failed to start database '/var/lib/hive/metastore/metastore_db' in hive 异常

我是hive的初学者。当我尝试执行任何配置单元命令时:hive>显示表格;它显示以下错误:FAILED:Errorinmetadata:javax.jdo.JDOFatalDataStoreException:Failedtostartdatabase'/var/lib/hive/metastore/metastore_db',seethenextexceptionfordetails.NestedThrowables:java.sql.SQLException:Failedtostartdatabase'/var/lib/hive/metastore/metastore_db',se

search - 使用 hadoop 进行日志搜索

我们在需要实时搜索的多个Web服务器上有巨大的日志文件(~100秒的Gigs)。这些日志文件由不同的应用每秒写入多次。为此,我们最近在一些服务器上安装了一个hadoop集群。为了实现对这些日志的搜索,我想到了这样的设计:在web服务器上运行一个进程,它创建一个日志的倒排索引并将其缓存在内存中(在web服务器本身上)并通过flume推送到HDFS当缓存已满时存储在Hive中(这很像LRU缓存)。这在搜索某些内容时有两种帮助:最近的日志从内存缓存中返回并且速度很快,而较旧的日志从磁盘返回。并且由于用户希望首先查看最新日志,因此该技术有效。有人可以验证此设计是否可以正常工作和缩放。周围有更好

hadoop - 使用配置单元初始化数据库时出现 java.sql.SQLException : Failed to start database 'metastore_db' ERROR,

我在3个集群上安装了Hadoop和Hive。我能够从运行HIVE的集群节点登录到配置单元。root@NODE_3hive]#hiveLogginginitializedusingconfigurationinjar:file:/usr/lib/hive/lib/hive-common-0.10.0-cdh4.2.0.jar!/hive-log4j.propertiesHivehistoryfile=/tmp/root/hive_job_log_root_201304020248_306369127.txthive>showtables;OKTimetaken:1.459secondsh

hadoop - DB2数据导入hadoop

我想将数据从DB2数据库导入到hadoop(HDFS,Hive)。一种方法是通过sqoop来做,我们可以用其他方法做同样的事情吗?请分享另一种方法。谢谢 最佳答案 Sqoop是最好的选择。其他任何事情都需要大量的自定义代码。我实际上参与过一个项目,我们有一个非常深奥的原因,我们不能使用Sqoop,但它最终并不是那么微不足道。您最终会担心转换类型、处理空值、编码、转义、重试、事务等等。为什么要重新发明轮子?我所知道的没有其他RDBMSHive连接器,因为Sqoop做得很好。除非您有非常充分、非常具体的理由不这样做,否则请使用Sqoop

mysql - Oozie - 运行 sqoop : Could not load db driver class: com. mysql.jdbc.Driver 时出现异常

我正在尝试通过Oozie在HDP沙箱2.1上执行sqoop导出。当我运行Oozie作业时,出现以下Java运行时异常。'>>>InvokingSqoopcommandlinenow>>>7598[main]WARNorg.apache.sqoop.tool.SqoopTool-$SQOOP_CONF_DIRhasnotbeensetintheenvironment.Cannotcheckforadditionalconfiguration.7714[main]INFOorg.apache.sqoop.Sqoop-RunningSqoopversion:1.4.4.2.1.1.0-385

hadoop - HBase 中有没有一种方法可以计算匹配 rowkey-search 的行

假设我的Rowkey有两部分(NUM1~NUM2)。我想按Rowkey的第一部分做一个计数组。有没有办法在HBase中执行此操作?我总是可以将其作为M/R作业读取所有行、组、计数...但我想知道是否有一种方法可以在HBase中执行此操作? 最佳答案 选项1:你可以使用prefixfilter....类似下面的内容。前缀过滤器:Thisfiltertakesoneargumentaprefixofarowkey.Itreturnsonlythosekey-valuespresentinarowthatstartswiththespec

sql - sqoop如何在向hive导入数据时自动修剪db2中的一些char类型的列?

我有一个很大的db2表,其中包含许多char类型的列。我尝试通过sqoop将数据提取到hive中以满足不同的需求。以前写Hivesql的时候都是手动把char类型的colums全部剪掉但是,有太多的列需要修剪,以至于我总是忘记其中的一些,这可能会导致一些困惑的问题,如下所示:假设BANK_TABLE是hive的目标表,2323423232323是表中已经存在的卡号。如果我执行:hive-e"select*fromBANK_TABLEwherecard_no='2323423232323'"结果是什么都没有,因为我在写sql导入数据到hive的时候忘记修剪了column:card_no所

hadoop - 在 Windows 上安装 Titan DB 时出错

遵循TitanDB的官方指南here,并尝试运行命令:graph=TitanFactory.open('conf/titan-cassandra-es.properties')我遇到了这个错误:Backendshorthandunknown:conf/titan-cassandra-es.properties很明显,原因是的路径不正确titan-cassandra-es.properties文件。所以我将其更改为:graph=TitanFactory.open('../conf/titan-cassandra-es.properties')得到这个错误:Encounteredunreg

hadoop - 将 rdd 从 spark 写入 Elastic Search 失败

我正在尝试在版本2.4.0上将一对rdd写入ElasticCloud上的ElasticSearch。我正在使用elasticsearch-spark_2.10-2.4.0插件写入ES。这是我用来写入ES的代码:defpredict_imgs(r):importjsonout_d={}out_d["pid"]=r["pid"]out_d["other_stuff"]=r["other_stuff"]return(r["pid"],json.dumps(out_d))res2=res1.map(predict_imgs)es_write_conf={"es.nodes":image_es,

【已解决】Error response from daemon: Get https://index.docker.io/v1/search?q=zookeeper&n=25: dial tcp: l

已解决:Errorresponsefromdaemon:Gethttps://index.docker.io/v1/search?q=zookeeper&n=25:dialtcp:lookupindex.docker.ioon192.168.xxx.x:xx:readudp192.168.xx.xx:xxxxx->192.168.xx.xx:xxxx:i/otimeoutdocker安装技术栈报错问题原因一:镜像源时国外的,下载被限制问题原因二:网络原因连接不通)docker安装技术栈报错在从Docker上pull镜像的时候遇到了如下问题:Gethttps://registry-1.docke