运行wordcount.java_运行hadoop wordcount程序

我正在通过以下michael-noll教程学习hadoop . 当我试图通过运行 hadoop jar hadoop-examples-1.2.1.jar wordcount tmp/Files tmp/Output 运行wordcount示例时,我收到以下错误:

13/11/10 18:09:42 INFO ipc.Client:重试连接到服务器:localhost / 127.0.0.1:54311 . 已经尝试了0次;重试策略是RetryUpToMaximumCountWithFixedSleep(maxRetries = 10,sleepTime = 1 SECONDS) . . 13/11/10 18:09:51错误security.UserGroupInformation:PriviledgedActionException as:hduser cause:java.net.ConnectException:调用localhost / 127.0.0.1:54311连接异常失败:java.net.ConnectException:Connection refused java .net.ConnectException:在连接异常时调用localhost / 127.0.0.1:54311失败:java.net.ConnectException:org.apache中的org.apache.hadoop.ipc.Client.wrapException(Client.java:1142)连接被拒绝.hadoop.ipc.Client.call(Client.java:1118)org.apache.hadoop.ipc.RPC $ Invoker.invoke(RPC.java:229)org.apache.hadoop.mapred . $ Proxy2.getProtocolVersion(来自sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)的sun.reflect.NativeMethodAccessorImpl.invoke0(本地方法)的sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang . 在org.apache.hadoop.io.retry.RetryInvocationHandler.invokeMethod(RetryInvocationHandler.ja)中反映.Method.invoke(Method.java:606) va:85)org.apache.hadoop.io.retry.RetryInvocationHandler.invoke(RetryInvocationHandler.java:62)org.apache.hadoop.mapred . $ Proxy2.getProtocolVersion(未知来源)org.apache.hadoop.ipc .RPC.checkVersion(RPC.java:422)在org.apache.hadoop.mapred.JobClient.createProxy(JobClient.java:559)在org.apache.hadoop.mapred.JobClient.init(JobClient.java:498)在org.apache.hadoop.mapred.JobClient(JobClient.java:479)在org.apache.hadoop.mapreduce.Job $ 1.run(Job.java:563)在java.security.AccessController.doPrivileged(本机方法)在javax.security.auth.Subject.doAs(Subject.java:415)在org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1190)在org.apache.hadoop.mapreduce.Job.connect(作业 . 的java:561)在org.apache.hadoop.mapreduce.Job.submit(Job.java:549)在org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:580)在org.apache.hadoop.examples .WordCount.main(WordCount.java:82)at sun.reflect.N的Sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)位于org.apache.hadoop.util的java.lang.reflect.Method.invoke(Method.java:606)的sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)中的ativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) .programDriver $ ProgramDescription.invoke(ProgramDriver.java:68)atg.apache.hadoop.util.ProgramDriver.driver(ProgramDriver.java:139)org.apache.hadoop.examples.ExampleDriver.main(ExampleDriver.java:64 )sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)at java.lang.reflect . 由org.apache.hadoop.util.RunJar.main(RunJar.java:160)引起的Method.invoke(Method.java:606):java.net.ConnectException:sun.nio.ch.SocketChannelImpl.checkConnect连接被拒绝(本机方法)位于org.apache.hadoop.net.Socket的sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:708) . IOWithTimeout.connect(SocketIOWithTimeout.java:206)在org.apache.hadoop.net.NetUtils.connect(NetUtils.java:511)在org.apache.hadoop.net.NetUtils.connect(NetUtils.java:481)在组织位于org.apache.hadoop.ipc.Client的org.apache.hadoop.ipc.Client $ Connection.setupIOstreams(Client.java:583)的.apache.hadoop.ipc.Client $ Connection.setupConnection(Client.java:457)位于org.apache.hadoop.ipc.Client.call的org.apache.hadoop.ipc.Client.getConnection(Client.java:1249)$ Connection.access $ 2200(Client.java:205)(Client.java:1093) ......还有33个

附录

我刚刚重新运行了这样的命令 bin/stop-all.sh , bin/start-all.sh , hadoop jar hadoop-examples-1.2.1.jar wordcount tmp/Files tmp/Output . 但现在我得到以下错误:

13/11/10 20时52分十二秒ERROR security.UserGroupInformation:PriviledgedActionException为:hduser原因:org.apache.hadoop.ipc.RemoteException:org.apache.hadoop.mapred.SafeModeException:JobTracker的是在组织安全模式 . 位于org.apache.hadoop.mapred.JobTracker.getStagingAreaDir(JobTracker.java:3677)的sun.reflect.NativeMethodAccessorImpl.invoke0(Native Methodsun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)位于org.apache的java.lang.reflect.Method.invoke(Method.java:606)的sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) .hadoop.ipc.RPC $ Server.call(RPC.java:587)org.apache.hadoop.ipc.Server $ Handler $ 1.run(Server.java:1432)org.apache.hadoop.ipc.Server $处理器$ 1.run(Server.java:1428)位于org.apache.hadoop.security.UserGroupInformation的javax.security.auth.Subject.doAs(Subject.java:415)的java.security.AccessController.doPrivileged(Native Method) .doAs(UserGroupInformation.java:1190)org.apache.hadoop.ipc.Server $ Handler.run(Server.java:1426)

org.apache.hadoop.ipc.RemoteException:org.apache.hadoop.mapred.SafeModeException:JobTracker在org.apache.hadoop的org.apache.hadoop.mapred.JobTracker.checkSafeMode(JobTracker.java:5188)处于安全模式.mapred.JobTracker.getStagingAreaDir(JobTracker.java:3677)at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

Plz的帮助

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/312287.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

EntityFramework Core动态加载模型,我们要知道些什么呢?

这篇文章源于一位问我的童鞋:在EntityFramework Core中如何动态加载模型呢?在学习EntityFramwork时关于这个问题已有对应童鞋给出答案,故没有过多研究,虽然最后解决了这位童鞋提出的问题,但是当我再次深入研究时&#…

C++多态的基本语法与原理剖析

多态分为两类 1.静态多态:函数重载和运算符重载属于静态多态,复用函数名 2.动态多态:派生类和虚函数实现运行时多态 静态多态和动态多态区别: 1.静态多态的函数地址早绑定,编译阶段确定函数地址 2.多态多态的函数地址…

从零开始开发 VS Code 插件之 Translator Helper

本文目录Translator Helper 介绍开发概述创建第一个VS Code Extension需求分析操作文本调用Google Translation API实现核心功能配置命令插件配置测试插件打包插件发布插件CI/CDIcon及README小结Translator Helper 介绍 微软 Docs 网站上线之后,我发现很多中文内容是…

java printf 版本_java – PrintStream类型中的printf(String,Object ...

为什么通过简单调用printf会出现以下编译错误?我的代码:import java.util.Scanner;public class TestCodeBankAccInputs{public static void main(String[] args){String displayName "Bank of America Checking";int balance 100;System.ou…

C++string容器-构造函数

本质: string是C风格的字符串,而string本质上是一个类 string和char区别: 1.char是一个指针 2.string是一个类,类内部封装了char*,管理这个字符串,是一个char*型的容器 string构造函数原型: 1…

【实战 Ids4】║ 又一个项目迁移完成(MVC)

迎周一,腊月十九,小年倒计时新年还有两周时间就要到了,学习可不能停,这几天一直在加班调休,周末也如此,不过也是趁着半夜凌晨的时间,继续迁移我的项目到IdentityServer4统一认证授权中心Blog.Id…

C++string容器-赋值操作

功能描述&#xff1a; 给string字符串进行赋值 代码如下&#xff1a; #include <iostream> using namespace std; #include <cstring>void test01() {string str1;str1 "hello world";cout << "str1 " << str1 << endl;…

C++生成随机数

C中生成随机数常用这两个函数&#xff1a; rand()和srand() rand()函数&#xff0c;生成一个范围在[0,RAND_MAX]的随机数&#xff0c;RAND_MAX的值为32767 其中RAND_MAX定义在cstdlib头文件中。 #include <iostream> using namespace std; #include <cstdlib>in…

JAVA解决生产消费者_Java常用三种方式解决生产者消费者问题(详细)

package test;/*** Synchronized 版本解决生产者消费者* wait() / notify()方法*/import java.util.LinkedList;import java.util.Queue;public class ProducerAndConsumerForSynchronized {// 1. 先定义最大生产长度private final int MAX_SIZE 10;// 2.定义储存队列private …

为什么说云原生会成为未来企业技术变迁的趋势

云原生是当下的热点话题&#xff0c;但是很多人对云原生有很多误解&#xff0c;特别是传统产业物联网或工控、物联网行业对云原生显得"后知后觉"。与其在这里说是预测&#xff0c;不如说是现在进行时&#xff0c;只是由于传统产业本身的技术包袱和组织个人认识程度差…

C++vector容器-构造函数

vector数据结构和数组非常相似&#xff0c;也称为单端数组&#xff0c;在数组的尾段可以做插入&#xff0c;删除操作 vector不同于普通数组&#xff0c;vector可以动态扩展 动态扩展&#xff1a;并不是在原空间之后续接新空间&#xff0c;而是找更大的内存空间&#xff0c;然…

java对象类型转换分为_java-如何将类对象转换为通用对象类型?

我正在研究一种使用NamedParameterJdbcTemplate从MySQL数据库获取一些数据的方法. listCurrentRecords应该从数据库返回Customer,Product和SalesOrder的对象类型列表. objectType是从在方法(1 || 2 || 3)内传递的参数定义的,并且在类中更早地定义为public变量.public static fi…

BeetleX网关之请求聚合

在网关服务中请求聚合是允许把多个请求打包成一个响应给请求方&#xff0c;这样不仅可以节省请求方的请求数量&#xff0c;还可以根据需求的情况整合不同业务数据响应请求。BeetleX.Bumblebee虽然并没有内置这一功能&#xff0c;但可以通过扩展的形式来支持请求聚合&#xff0c…

C++vector容器-赋值操作

vector赋值操作 功能描述&#xff1a; 给vector容器进行赋值 函数原型&#xff1a; 代码如下&#xff1a; #include <iostream> using namespace std; #include <vector> //vector赋值操作void printVector(vector<int> &v) {for (vector<int >…

java 计算i 出现的次数_JAVA算法:按照给定的段落统计单词出现次数(JAVA代码)...

https://blog.csdn.net/seagal890/article/details/92067644JAVA算法&#xff1a;按照给定的段落统计单词出现次数(JAVA代码)写一个 JAVA程序以统计一个文本文件 words.txt 中每个单词出现的频率。为了简单起见&#xff0c;你可以假设&#xff1a;words.txt只包括小写字母和 …

EntityFramework Core表名原理解析,让我来,揭开你神秘的面纱

上一节我们针对最开始抛出的异常只是进行了浅尝辄止的解析&#xff0c;是不是有点意犹未尽的感觉&#xff0c;是的&#xff0c;我也有这种感觉&#xff0c;看到这里相信您和我会有一些疑惑&#xff0c;要是我们接下来通过注解、Fluent APi、DbSet分别对表名进行如下设置&#x…

C++vector容器-容量和大小

vector容量和大小 功能描述&#xff1a; 对vector容器的容量和大小操作 函数原型&#xff1a; 代码如下&#xff1a; #include <iostream> using namespace std; #include <vector> //vector容器的容量和大小操作void printVector(vector<int > &v) {…

openresty+mysql+乱码_openresty记录响应body乱码问题

问题背景最近新上了一个功能&#xff0c;openresty通过syslog记录请求日志&#xff0c;然后由logstash推送至ES。测试上线时未发现这个问题&#xff0c;在日常查看日志的过程中&#xff0c;发现logstash推送有错误日志&#xff0c;错误内容为&#xff1a;Error parsing json&am…

【Azure学习.01】先从账号注册开始

本文部分内容配套视频&#xff1a;https://www.bilibili.com/video/av82898957马上要放假了&#xff0c;决定在家里简单了解一下Azure云服务&#xff0c;虽然公司其他部分用到了这个Azure&#xff0c;但是我还是没有接触到&#xff0c;只是听说很贵&#xff0c;好几千每天&…

C++vector容器-插入和删除

vector插入和删除 功能描述&#xff1a; 对vector容器进行插入&#xff0c;删除操作 函数原型&#xff1a; 代码如下&#xff1a; #include <iostream> using namespace std; #include <vector> //vector插入和删除void printVector(vector<int > &v…