草庐IT

hadoop - 在Hadoop中,复制因子和集群中的节点数之间有什么关系?

例如,如果复制因子为3,并且集群中有2个节点。那么将创建多少个副本?它们将如何放置? 最佳答案 复制因子大于可用数据节点会破坏复制的目的。副本应该明确且唯一地放置在数据节点上。如果一个数据节点包含同一个block的多个副本(理论上),它不会提供额外的容错能力,因为如果该节点出现故障,两个副本都会丢失。因此每个节点只有一个副本就足够了。并回答您的问题:Whatistherelationshipbetweenreplicationfactorandnumberofdatanodesincluster?Ans.Maximumreplica

hadoop - 确定 Apache Spark 作业中的当前 Kerberos 用户

我在支持Kerberos的集群(Cloudera)上运行Spark作业,并希望能够为作业的任何给定运行记录用户的Kerberos身份。(注意这里不是启动job的本地linux用户身份,因为我们使用keytab文件,jaas.conf文件,调用kinit启动脚本。我们可以在启动脚本中记录一个身份,因为我们知道与key表一起传递给kinit的主体,但是能够在实际的Spark作业本身中登录会很好,这样即使一个作业是手动启动的,我们也能可靠地知道它在什么身份下运行)。一些答案​​表明如下:importjava.security.{AccessController,Principal}impor

hadoop - Hive 中的 RANK OVER 函数

我试图在Hive中运行此查询以仅返回在adimpression表中出现频率最高的前10个url。selectranked_mytable.url,ranked_mytable.cntfrom(selectiq.url,iq.cnt,rank()over(partitionbyiq.urlorderbyiq.cntdesc)rnkfrom(selecturl,count(*)cntfromstore.adimpressionaiinnerjoinzuppa.adgroupcreativesubscriptionagcsonagcs.id=ai.adgroupcreativesubscri

hadoop - hadoop 中找不到或加载主类错误

Here是下面的教程。当我尝试执行命令bin/hadoopnamenode-format时出现错误。错误是:Error:Couldnotfindorloadmainclassorg.apache.hadoop.util.PlatformNameDEPRECATED:Useofthisscripttoexecutehdfscommandisdeprecated.Insteadusethehdfscommandforit.Error:Couldnotfindorloadmainclassorg.apache.hadoop.util.PlatformNameError:Couldnotfin

java - hadoop 一个字段的不同计数

我有一个文件,其格式如下:1,53212345671,53245643211,53245643212,12345676432,12345676662,98754223453,53444353453,53444353453,53444353453,53444353453,53453453123,8767564564在reduce过程结束时,我希望第二个字段的不同计数与第一个字段是关键。例如1,22,33,3为此,Java中最简单的map和reduce函数是什么?谢谢。 最佳答案 如果我正确理解您的目标,您需要:使每个键的值唯一计算每个

hadoop - Neo4j 可以与 Hadoop 一起工作吗?

Neo4j能否与Hadoop一起用于大数据的社交网络分析?如果是,是否很难让它们一起工作,这样一个系统的瓶颈是什么?基本上,我正在寻找一种用于大数据社交网络分析的解决方案,该网络可能有数亿个顶点。我还期待一个用户友好的图形用户界面,用于图形的交互式探索和分析。Hadoop+Neo4j是否适合上述用途?还是Hadoop+Griph或Spark+GraphX更好?如有任何意见或建议,我们将不胜感激。谢谢。 最佳答案 Spark+GraphX为您提供更快的性能。这是派生的Pregal和GraphLab库。但它没有任何UI可以直接查看图形输

hadoop - 如何使用 hadoop 在 cassandra 中运行字数统计示例?

我可以使用hadoop运行字数统计,现在我想将cassandra与hadoop结合使用。我想在cassandra中运行字数统计示例,但我不明白该怎么做。我通读了示例中的自述文件,但它没有提及如何或何时启动hadoop。我有点困惑。我怎样才能做到这一点?逐步解释会很有帮助。问候, 最佳答案 我做过一次并在这里做了一些笔记http://blog.alvazan.com/165/how-to-set-up-the-cassandra-wordcount-example/ 关于hadoop-如何

hadoop - hadoop-env.sh 文件中的语法错误

我决定使用hadoop2.5.0我设置了HADOOP_PREFIX,但是当我想查看版本或格式namenode时,发生了这个错误:[hdfs@master1bin]$./hadoopversion:commandnotfound.5.0/etc/hadoop/hadoop-env.sh:line16::commandnotfound.5.0/etc/hadoop/hadoop-env.sh:line18::commandnotfound.5.0/etc/hadoop/hadoop-env.sh:line23::commandnotfound.5.0/etc/hadoop/hadoop-e

hadoop - 将列添加到Hive外部表错误

尝试将列添加到配置单元中的外部表,但出现以下错误。这个表目前已经注册了1000个分区,我希望避免重新创建这个表,然后运行msckrepair,这需要很长时间才能完成。此外,该表使用opencsvserde格式。如何添加列hive>ALTERTABLEschema.Table123ADDCOLUMNS(Column1000STRING);FAILED:ExecutionError,returncode1fromorg.apache.hadoop.hive.ql.exec.DDLTask.Unabletoaltertable.java.lang.IllegalArgumentExcepti

servlets - Hadoop 之上的 Servlet 容器?

我正处于一个大项目的架构阶段,我决定使用hbase作为我的数据库,并将使用map/reduce作业进行处理,因此我的架构完全在hadoop下工作。问题是我还需要实现一些REST、SOAPAPI的一些网页,所以我在想是否有任何运行在hadoop之上的servlet容器,以便我的系统保持冗余和分布式,而不必担心二级集群机制(因为我已经为hadoop设置了一个)。那么有没有运行在hadoop之上的servlet容器,比如运行在hadoop之上的hbase(数据库)? 最佳答案 它不完全是一个servlet,但您可能对Stargate提供的