MapReduce系列-eclipse运行MapReduce

2023-05-16

1、eclipse安装hadoop的插件
下载 hadoop-eclipse-plugin-2.6.0.jar,将其放入 eclipse 的 \plugins 目录,并重启 eclipse,项目视图(Project Explorer)会多出一个DFS Locations文件夹,在 Window—>Show View—>Other—>MapReduce Tools—>Map/Reduce Locations,会在Console栏位多出一个Map/Reduce Locations
下载地址: https://github.com/winghc/hadoop2x-eclipse-plugin
2、插件配置
在Map/Reduce Locations栏位下空白的地方右键—>New Hadoop Location
LocationName:自己命名
Map/Reduce(V2) Master:HOST随意,Port随意,这两个地方不用配置对,因为mapreduce没有提交到Hadoop集群上运行的,而是在本地运行的。
DFS Master:Host为HDFS NameNode节点的IP,Host为负责接收Client连接的RPC端口,用于获取文件系统metadata信息。这两个配置对应fs.defaultFS配置的ip和端口
配置完成后右键点击DFS Locations下面创建的Location(明智就是上面配置的LocationName),点击Reconnect,这时候会看到HDFS的文件目录,如果出错,那应该是Map/Reduce(V2) Master的Host和Port没有配置正确,修改后重新Reconnect,直到连接到HDFS为止
3、写一个MapReduce应用
4、异常处理
(1)、HDFS权限(如果MapReduce输入输出路径是本地目录,则不会出现下面异常)
异常信息:org.apache.hadoop.security.AccessControlException: Permission denied: user=dwdw, access=WRITE, inode="/":hdfs:supergroup:drwxr-xr-x
解决方案:在 mapred-site.xml 配置文件中设置属性 dfs.permission 为 false 即可
(2)、NativeIO异常
异常信息:org.apache.hadoop.io.nativeio.NativeIO$Windows.access0(Ljava/lang/String;I)Z
解决方案:解压自己对应版本的hadoop-common源码包,把org.apache.hadoop.io.nativeio.NativeIO.java拷贝到MapReduce项目中,注意,拷贝后NativeIO.java包名是org.apache.hadoop.io.nativeio,这样才能覆盖hadoop-common包下面的代码,然后修改access方法的方法体,直接return true,修改后代码如下:
public static boolean access(String path, AccessRight desiredAccess)
throws IOException {
return true;
}
备注:其它异常看日志解决就好。暂时没遇到其它异常
5、运行结果
完成上面的异常处理后就可以正确的运行MapReduce,可以注意到,MapReduce并没有提交到Yarn或者Hadoop集群上运行,只是把结果集保存在Hadoop集群的HDFS文件目录下。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

MapReduce系列-eclipse运行MapReduce 的相关文章

  • 从不同的插件执行现有插件的命令/处理程序

    我有一个 RCP 应用程序 其中包含现有命令和处理程序 可以通过编程方式切换视角 我还有现有 RCP 应用程序使用的新插件 我希望这个新插件执行我的 RCP 应用程序的命令 处理程序 可能的解决方案是什么 您可能需要为该命令定义一个处理程序
  • 如何在 Java/Eclipse 中使用特殊字符

    如何在 Java Eclipse 中使用 显示 或 等字符 当我尝试直接使用它们时 例如在源代码中 Eclipse无法保存文件 我能做些什么 编辑 如何找到 unicode 转义序列 问题是您使用的字符无法以文件设置的编码 Cp1252 表
  • 设计抽象类时是否应该考虑序列化问题?

    一般来说这个问题来自Eclipse建议在抽象类上添加串行版本UID 由于该类是抽象类 因此该类的实例永远不会存在 因此它们永远不会被序列化 只有派生类才会被序列化 所以我的问题是放置一个安全 SuppressWarnings serial
  • 以编程方式检查 .class 文件是否扩展特定类

    我有一个问题 我已经尝试解决好几个小时了 在 Eclipse 插件中 我有一个 ArrayList 其中包含一些 java class 文件的完整路径 作为字符串 我想做的是检查列表中包含的类是否扩展了特定的类 我考虑过解析该文件 查找 e
  • Android:R 类停止生成

    我是 android 编程的新手 我正在做 Commsware 教程中的教程 确切地说是 T3 教程 期间我清理了项目 之后 R 类文件停止生成 我删除了该项目 看起来相同的错误正在传播到我正在创建的其他新项目 新创建的项目也会出现此错误
  • (更好的方法)使用 Eclipse 和 XText 获取项目中的文件

    我正在编写一个 XText 编辑器 并进行一些语义突出显示 我正在解析的部分语言引用了文件 这些文件应该存在于项目中 我想根据这些文件是否位于正确的位置来突出显示 目前 我有一个非常丑陋的解决方案 但我确信有更好的方法 public voi
  • 在 Eclipse 中的调试会话期间记录所有跟踪信息

    我想记录调试会话的每个步骤的所有调试信息 以便稍后处理所有这些数据 例如调用的方法的名称 参数值 所有变量值等 有没有任何选项可以实现此目的 我应该在哪里更改代码才能实现此目的 一件重要的事情 它不是一个 java 程序 这是一个使用 ac
  • 在 Eclipse 插件中:如何以编程方式突出显示 java 编辑器中的代码行?

    我正在尝试开发一个 eclipse 插件 它对 java 代码进行一些文档检查 并在编辑器中突出显示一些代码行 为了实现我的目标 我不想在 eclipse 中创建新的编辑器 我只是想扩展默认的 java 编辑器以在不满足某些预定要求的方法下
  • 尝试通过 Java 8 中的 JDBC-ODBC 连接到 .accdb 文件时出现 ClassNotFoundException

    我正在 Eclipse EE IDE 中的 Java 项目中工作 我必须在其中查询 accdb文件 问题是当我尝试加载驱动程序然后连接到数据库时 它给了我一个异常错误 My code try String filePath myfilepa
  • 新的 Android 项目未创建布局或 Java 文件

    这两天我一直在尝试简单地阅读 Big Nerd Ranch Android 编程书 第一章的前几页 我的问题的要点是 当我创建新的 Android 应用程序时 不会创建布局或 java 文件 我已经从 Android 开发站点安装了 ADT
  • 是否有用于封闭类型名称的简短版本的 Eclipse 模板变量

    我想在 Eclipse 中为 Java 类创建一个构造函数模板 我有一个适用于大多数课程的版本 尽管它不适用于嵌套在其他类中的类 见类Inner如下 如何获得类名的简短版本 模板不起作用 public newType enclosing t
  • 将 Boost 库添加到 Windows Eclipse 中的 C++ 项目

    我最近使用安装程序在 Windows 上安装了 Boost 库 我试图链接到 Eclipse 中的库 但运气不佳 我尝试浏览 Project Properties gt C C Build gt Settings gt MinGW C Li
  • Riak 在 MapReduce 查询中失败。使用哪种配置?

    我正在与 riak riak js 结合开发一个 nodejs 应用程序 并遇到以下问题 运行此请求 db mapreduce add logs run 正确返回存储在存储桶日志中的所有 155 000 个项目及其 ID logs 1GXt
  • Java:同步标准输出和标准错误

    我有一个奇怪的问题 如果我能解决它就好了 出于调试目的 以及其他一些事情 我在标准输出上编写控制台 Java 应用程序的日志 有些内容写在标准输出上 有些内容 例如错误 打印在标准错误上 问题是这两者并不完全同步 因此打印行的顺序并不总是正
  • 如何在Eclipse中集成CSS预处理? [关闭]

    Closed 此问题正在寻求书籍 工具 软件库等的推荐 不满足堆栈溢出指南 help closed questions 目前不接受答案 我想在 Eclipse 中编辑 SCSS 文件 最好使用语法突出显示 scss files 我发现这些资
  • Android ADT Eclipse 插件,parseSDKContent 失败

    我刚刚设置了我的第一个 Android 开发环境 其中包括 日食3 5 Mac OS X 10 5 适用于 x86 mac 的 Android SDK ADT Eclipse 插件 0 9 6 我已将 set PATH 设置为我的 SDK
  • 在java库中找不到源

    I m new to java and facing this problem while debugging code 我在使用外部文件时发现了 rt jar 但不起作用 这是否意味着该文件已损坏还是什么 您需要附加 src zip 作为
  • Maven依赖log4j错误

    大家好 我遇到错误 无缘无故地破坏了我的构建 这是错误消息 error error reading m2 repository com sun jdmk jmxtools 1 2 1 jmxtools 1 2 1 jar error in
  • 如何在 Windows 上的 Eclipse 中设置 Clang 工具链?

    我为一个愚蠢的问题道歉 但我在网上找不到答案 我正在努力为 64 位计算机上的 Windows 7 中的 Eclipse 设置 Clang 编译器 链接器 我对 C 的了解非常过时 并且从未在 Eclipse 中工作过 我想要实现的是在 W
  • 如何在 Eclipse .classpath 文件中使用环境变量?

    在 Windows 中 我有一个环境变量 EXTERNAL LIB ROOT 指向 C Program Files MyExternalLibRoot 在另一台计算机上 它可能指向 C ExternalLibs 在 ant build xm

随机推荐

  • 正点原子STM32F407+ESP8266开发上篇

    说起机智云 xff0c 真是对物联网技术小白来说太人性化了 xff0c 对物联网感兴趣的的小白 xff0c 只需会学会看懂代码中的接口 xff0c 可以先不用学会网络协议 xff08 当然这个肯定要学的 xff09 xff0c 即可轻松将数
  • ubuntu下安装cmake及cmake简单使用,CmakeList的编写和参数详解

    安装过程 首先去官网下载安装包 选择 XX tar gz 源码安装包 输入如下命令 tar zxvf xx tar gz bootstrap make make install 输入以上命令后就已经可以在ubuntu上安装好cmake 编写
  • ROS中两个电脑之间ssh通信(ROS多机通信计算机网络配置)

    ROS中两个电脑之间ssh通信 PC 即个人电脑 xff0c ip是202 204 53 186 图一 xff1a PC bashrc 图二 xff1a PC hosts pc上终端启动 xff1a ssh robot 64 202 204
  • rosdep init

    本文之后 xff0c 世上再无rosdep更新失败问题 xff01 如果有 小鱼就
  • Hadoop中查看HDFS中的一个文件的位置信息

    指令 hadoop fsck user hadoop filename files blocks locations racks files 文件分块信息 xff0c blocks 在带 files参数后才显示block信息 locatio
  • ROS 安装与测试& RVIZ 运行仿真机械臂

    本文用于学习记录 文章目录 前言一 ROS 安装1 1 设置安装源1 2 设置 key1 3 更新 apt1 4 安装 ros 二 ROS 环境配置2 1 配置环境变量2 2 安装构建依赖相关工具2 3 初始化 rosdep2 4 替换 2
  • 自抗扰控制器-1.跟踪微分器 TD

    传统控制方法大都基于设定值与系统输出的残差的生成控制量 xff0c 这就是让有惯性输出信号跟踪存在跳变的设定值信号 xff0c 最初阶段残差过大 xff0c 容易导致超调 为了克服这个缺陷 xff0c 研究人员采用微分器来获得信号的微分信号
  • 自抗扰控制器-3.状态观测器(一)

    状态观测器 ESO 状态观测器 Extended State Observer ESO 定义 xff1a 根据外部变量的观测来确定系统内部状态变量的装置叫做状态观测器 xff0c 即根据测量到的系统输入 xff08 控制量 xff09 和系
  • 自抗扰控制器-6线性自抗扰控制器LADRC

    二阶线性自抗扰控制器结构图如下图所示 xff1a xff08 1 xff09 线性扩张状态观测器 LESO 依然属于 LADRC 的中枢核心环节 xff0c 而且 LESO 和 ESO 的功能基本 一致 xff0c 都是针对系统 总扰动 进
  • 无人机学习Pix4

    pix4学习 IMU xff08 惯性测量单元 xff09 IMU用来检测当前飞机的姿态 xff0c 飞控根据当前姿态做出调整 xff0c 保证飞机飞行稳定 俯仰角 pitch xff08 前后翻滚 xff09 横滚角 roll xff08
  • 修改Mysql root密码

    最近新装好的mysql在进入mysql工具时 xff0c 总是有错误提示 mysql uroot p Enter password ERROR 1045 28000 Access denied for user 39 root 39 64
  • 示例:PX4——添加msg、uORB

    git clone https github com PX4 Firmware cd Firmware git submodule update init recursive git checkout v1 11 0 beta1 make
  • PX4飞控读取UART串口信息通过Mavlink传给QGC地面站显示

    详细代码地址 xff1a https github com XXXUUUXXX PX4 2 QGC 目的 xff1a 通过UART串口给PX4飞控发送信息 xff0c 通过Mavlink协议在QGC界面上显示出来 显示信息包括 xff1a
  • QGC地面站连接多机飞控PX4

    环境 xff1a QGC4 1飞控1飞控2 首先 xff0c 连接飞控1 xff0c 修改参数MAV SYS ID 61 1 然后 xff0c 断开飞控1 xff0c 连接飞控2 xff0c 修改参数MAV SYS ID 61 2 关闭自动
  • PX4 mavros可以切换的模式

    catkin ws src mavros mavros src lib uas stringify cpp PX4 custom mode gt string static const cmode map px4 cmode map px4
  • Jetson的mavros使用offboard模式,终端按键控制无人机飞行

    基于Promethues根据wiki配置好之后可以实现使用终端控制 xff0c 起飞 xff1b 降落 xff1b 前后左右飞行 xff1b 上升下降左转右转 xff1b 开始我基于仿真测试实机不成功 xff0c 是因为某个运行节点没有打开
  • 安装Mavros——二进制方法

    sudo apt get install ros melodic mavros ros melodic mavros extras wget https raw githubusercontent com mavlink mavros ma
  • 【LADRC】线性自抗扰控制

    目录 LADRC算法 LADRC算法推导二阶线性系统为例 LADRC算法n阶 LADRC离散化 零阶保持法 一阶系统 二阶系统 LADRC参数整定方法 参考文献 LADRC算法 自抗扰控制 xff08 ADRC xff0c Active D
  • 控制笔记(自控+现控)

    目录 主流控制方法优缺点 干扰观测器 水床效应 PID 积分分离 饱和区 积分饱和 微分使用条件 死区 中性区 不作用区 动态性能指标 主流控制方法优缺点 PID 优点 xff1a 实现简单 不依赖模型缺点 xff1a 在系统平衡点附近设计
  • MapReduce系列-eclipse运行MapReduce

    1 eclipse安装hadoop的插件 下载 hadoop eclipse plugin 2 6 0 jar xff0c 将其放入 eclipse 的 plugins 目录 xff0c 并重启 eclipse xff0c 项目视图 xff