草庐IT

hadoop-examples

全部标签

hadoop - 随着集群规模的增加,每个节点并发运行的映射器数量在 Elastic MapReduce w/AMI 3.1.0 和 Hadoop 2.4.0 上急剧下降

在相关问题(HowtosettheprecisemaxnumberofconcurrentlyrunningtaskspernodeinHadoop2.4.0onElasticMapReduce)中,我要求提供将并发运行的映射器/缩减器的数量与YARN和MR2内存参数相关联的公式。事实证明,在ElasticMapReduce上,当我的集群有2到10个c3.2xlarge节点时,那里提到的公式的变体工作正常,每个节点有7-9个并发运行的映射器;但是当c3.2xlarges的数量为20或40时,我发现集群未充分利用:每个节点仅运行1-4个映射器。由于我的工作受CPU限制,这尤其糟糕:MR2

python - 如何从 hadoop python 包装器运行 C++ 可执行文件

我是使用python的hadoop流媒体库的新手。所以这个问题可能看起来很愚蠢,但我被困在这里了。感谢您的帮助。我正在尝试从用作hadoop映射器的python代码运行C++可执行文件(它将本地文件名作为命令行参数并在本地文件系统中写入文件)。C++代码在本地文件系统中运行良好。此外,当我从python调用它时,它在本地文件系统中工作正常。但是,无论何时,我都试图将python称为hadoop,映射器它不起作用。这是什么原因呢?有什么想法吗? 最佳答案 假设您可以验证您的Python代码能够在本地执行二进制文件,您应该确保将C++二

java - Hadoop 字数统计期间出现异常

我已经成功安装了Hadoop,现在我想运行Wordcount.jar。如下图,我的源地址是/user/amir/dft/pg5000.txt,保存结果的目的地址是/user/amir/dft/output.txt。我已经从thisurl下载了.jar文件.现在我在运行以下命令时遇到此错误消息。我按照thisurl中的说明进行操作现在我的问题是“运行MapReduce作业”这一步。我该如何克服它?amir@amir-Aspire-5820TG:/usr/local/hadoop$bin/hadoopjar/usr/local/hadoop/wordcount.jarwordcount/u

hadoop - 在 Hadoop 中将 dfs.blocksize 设置为 100Kb

我尝试将Hadoop中的dfs.blocksize设置为100Kb,这小于默认的dfs.namenode.fs-limits.min-block-size,这是1MB。当我复制文件时hdfsdfs-Ddfs.namenode.fs-limits.min-block-size=0-Ddfs.blocksize=102400inp.txt/input/inp.txt我还是明白了,copyFromLocal:Specifiedblocksizeislessthanconfiguredminimumvalue(dfs.namenode.fs-limits.min-block-size):102

单台机器上的 Hadoop 多个数据节点

我有兴趣在一台Linux机器上配置多个数据节点(比如2个)。我做了一些研究并遵循了教程,但没有奏效。如果有人可以提供工作教程或告诉我如何去做。谢谢 最佳答案 您可以在同一节点本身中运行多个数据节点实例,而不是创建单独的VM。唯一的问题是您必须为每个数据节点实例维护不同的配置。需要为每个datanode守护进程指定不同的端口覆盖hdfs-site.xml中的以下参数:dfs.datanode.address0.0.0.0:50010Thedatanodeserveraddressandportfordatatransfer.dfs.d

hadoop - 在hive(hadoop)中添加文件后,在仓库中不可见?

我可以像这样在配置单元中添加一个文件:hive>addfile/home/vis/Documents/def.txt;hive>listfiles;/home/vis/Documents/def.txt现在的问题是,上面的文件在我的仓库里是看不到的。是否可以在hive仓库(/user/hive/warehouse)中看到。如果没有,那么我如何在配置单元中看到该文件? 最佳答案 Hiveaddcommandputsthefileindistributedcache.这是mapred.local.dir。分布式缓存旨在分发需要存在于所有

hadoop - Sqoop 运行到本地作业运行器模式

当我运行sqoop时,我不确定它为什么会进入本地作业运行器模式,然后说我为LocalJobRunner提供了无效的jobtrackerurl。谁能告诉我这是怎么回事?$bin/sqoopimport-jtmyjobtracker:50070--connectjdbc:mysql://mydbhost.com/mydata--usernamefoo--passwordbar--as-parquetfile--tablecampaigns--target-dirhdfs://myhdfs:8020/user/myself/campaigns14/08/2021:04:50INFOsqoop

hadoop - Zookeer是hadoop的一部分还是单独配置?

正如我从各种tuts中读到的那样,zookeeper有助于协调和同步各种hadoop集群。目前我安装的是hadoop2.5.0。当我执行jps时,它会显示4494SecondaryNameNode8683Jps4679ResourceManager3921NameNode4174DataNode4943NodeManager动物园管理员没有进程。我怀疑zookeeper是hdfs的一部分还是我们需要手动安装? 最佳答案 如果你只使用hadoop,不需要zookeeper!hadoop中的其他工具,比如hbase,就看zookeepe

hadoop - giraph/hadoop 读取 list 文件

我正在尝试运行RandomWalkWithRestart示例https://github.com/apache/giraph/blob/release-1.0/giraph-examples/src/main/java/org/apache/giraph/examples/RandomWalkWithRestartVertex.java我的输入是数据是12345634785634787834我正在运行hadoopjargiraph-examples-1.1.0-for-hadoop-2.2.0-jar-with-dependencies.jarGiraphRunner-Dgiraph.

java - 如何使用 Hadoop Mapreduce 运行非 Java 程序(首选 C++/Matlab)

我有一个要求,说明C++和Matlab算法的执行应该从Hadoopmapreduce编程触发。这会映射要分发的执行算法吗。因为我们没有计划使用整个mapreduce程序重写算法 最佳答案 在R2014b中,MATLAB允许从MATLAB内部进行mapreduce并与Hadoop集成。我不能确定你的具体用例,但你可能想检查一下:http://www.mathworks.com/help/matlab/mapreduce.htmlhttp://www.mathworks.com/discovery/matlab-mapreduce-ha