Skip to content

Latest commit

 

History

History
120 lines (84 loc) · 5.8 KB

Running-Hadoop-MapReduce-on-Alluxio.md

File metadata and controls

120 lines (84 loc) · 5.8 KB
Raw
layout title nickname group priority
global
在Alluxio上运行Hadoop MapReduce
Apache Hadoop MapReduce
Frameworks
1
  • 内容列表 {:toc}

该文档介绍如何让Alluxio与Apache Hadoop MapReduce一起运行，从而让你轻松地运行文件存储在Alluxio上的MapReduce程序。

初始化设置

该文档的先决条件包括： － 你已安装了Java。 － 你已经按照这些文档建立了一个Alluxio集群：本地模式或集群。 － 为了运行一些简单的map-reduce实例，我们也推荐你下载根据你的hadoop版本对应的map-reduce examples jar，或者如果你正在使用Hadoop 1，下载这个examples jar。

编译Alluxio客户端

为了使MapReduce应用可以与Alluxio进行通信，你需要将Alluxio Client的Jar包包含在MapReduce的classpaths中。我们建议你从Alluxio download page 下载压缩包。Alluxio Client的Jar包可以在{{site.ALLUXIO_CLIENT_JAR_PATH_HADOOP}}路径中找到。

同时，高级用户可以选择使用源代码来编译生成Alluxio Client的Jar包。 你可以在Alluxio目录下运行以下命令：

mvn install -P<HADOOP_PROFILE> -DskipTests

对于不同的Hadoop发行版本，可用的Hadoop配置文件包括“hadoop-1”，“hadoop-2.2”，“hadoop-2.3”...“hadoop-2.8”。你也可以进一步设置一个特定的Hadoop发行版本进行编译，比如：

mvn install -Phadoop-2.7 -Dhadoop.version=2.7.1 -DskipTests

编译成功后，新的Alluxio客户端Jar包可以在{{site.ALLUXIO_CLIENT_JAR_PATH}}中发现; 文档后续部分将会用到这个jar文件。

配置Hadoop

将以下三个属性添加到Hadoop的安装目录下的conf目录中的core-site.xml文件中：

<property>
  <name>fs.alluxio.impl</name>
  <value>alluxio.hadoop.FileSystem</value>
  <description>The Alluxio FileSystem (Hadoop 1.x and 2.x)</description>
</property>
<property>
  <name>fs.AbstractFileSystem.alluxio.impl</name>
  <value>alluxio.hadoop.AlluxioFileSystem</value>
  <description>The Alluxio AbstractFileSystem (Hadoop 2.x)</description>
</property>

该配置让你的MapReduce作用在输入和输出文件中通过Alluxio scheme（比如alluxio://）来识别URIs。

其次, 在conf目录中hadoop-env.sh文件中修改$HADOOP_CLASSPATH：

export HADOOP_CLASSPATH={{site.ALLUXIO_CLIENT_JAR_PATH}}:${HADOOP_CLASSPATH}

该配置确保Alluxio客户端jar包是利用的，对于通过Alluxio的URIs来创建和提交作业进行交互的MapReduce作业客户端。

分发Alluxio客户端Jar包

为了让MapRedude应用可以在Alluxio上读写文件，Alluxio客户端Jar包必须被分发到不同节点的应用相应的classpaths中。

如何从Cloudera上加入第三方库这篇文档介绍了分发Jar包的多种方式。文档中建议通过使用命令行的-libjars选项，使用分布式缓存来分发Alluxio客户端Jar包。另一种分发客户端Jar包的方式就是手动将其分发到Hadoop节点上。下面就是这两种主流方法的介绍：

1.使用-libjars命令行选项 你可以在使用hadoop jar ...的时候加入-libjars命令行选项，指定{{site.ALLUXIO_CLIENT_JAR_PATH}}为-libjars的参数。这条命令会把该Jar包放到Hadoop的DistributedCache中，使所有节点都可以访问到。例如，下面的命令就是将Alluxio客户端Jar包添加到-libjars选项中。

bin/hadoop jar libexec/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.3.jar wordcount -libjars {{site.ALLUXIO_CLIENT_JAR_PATH}} <INPUT FILES> <OUTPUT DIRECTORY>

2.手动将Client Jar包分发到所有节点 为了在每个节点安装Alluxio,将客户端jar包{{site.ALLUXIO_CLIENT_JAR_PATH}}置于每个MapReduce节点的$HADOOP_HOME/lib（由于版本不同也可能是$HADOOP_HOME/share/hadoop/common/lib），然后重新启动Hadoop。 另一种选择，在你的Hadoop部署中，把这个jar包添加到mapreduce.application.classpath系统属性，确保jar包在classpath上。 为了在每个节点上安装Alluxio，将客户端Jar包mapreduce.application.classpath，该方法要注意的是所有Jar包必须再次安装，因为每个Jar包都更新到了最新版本。另一方面，当该Jar包已经在每个节点上的时候，就没有必要使用-libjars命令行选项了。

在本地模式的Alluxio上运行Hadoop wordcount

为了方便，我们假设是伪分布式的集群，通过运行如下命令启动(根据hadoop的版本，你可能需要把./bin换成./sbin)：

cd $HADOOP_HOME
bin/stop-all.sh
bin/start-all.sh

以本地模式启动Alluxio：

bin/alluxio-start.sh local

你可以在Alluxio中加入两个简单的文件来运行wordcount。在你的Alluxio目录中运行：

bin/alluxio fs copyFromLocal LICENSE /wordcount/input.txt

该命令将LICENSE文件复制到Alluxio的文件命名空间中，并指定其路径为/wordcount/input.txt。

现在我们运行一个用于wordcount的MapReduce作业。

bin/hadoop jar libexec/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.3.jar wordcount -libjars {{site.ALLUXIO_CLIENT_JAR_PATH}} alluxio://localhost:19998/wordcount/input.txt alluxio://localhost:19998/wordcount/output

作业完成后，wordcount的结果将存在Alluxio的/wordcount/output目录下。你可以通过运行如下命令来查看结果文件：

bin/alluxio fs ls /wordcount/output
bin/alluxio fs cat /wordcount/output/part-r-00000