草庐IT

mapreduce-name

全部标签

hadoop - 当我点击 jps 命令时,namenode datanode 和 sec name node 没有启动

我在Ubuntu中以伪分布式模式使用Hadoop1.2.1,一切正常。但后来我不得不重新启动我的系统。现在,当我在给出start-all.sh后点击jps命令时,我只能看到tasktracker和jobtracker正在运行。谁能告诉我这个问题的可能原因?并指导我解决这个问题?************************************************************/2017-03-1318:41:16,733INFOorg.apache.hadoop.hdfs.server.datanode.DataNode:STARTUP_MSG:/*********

Hadoop Mapreduce 功能

假设我想使用"OrderBy"子句执行Select查询,并且我的数据分布在多台机器上。Map如何减少获取数据以及它在哪里执行“OrderBy”查询。 最佳答案 Map-Reduce可用于实现分布式“OrderBy”。...OneofYahoo’sHadoopclusterssorted1terabyteofdatain209seconds...Thesortused1800mapsand1800reduces...ApacheHadoopWinsTerabyteSortBenchmark这可以通过按值将顺序键映射到范围来完成。然而,

hadoop - Hadoop 2.7在windows 7 64位启动时 : Name or service not knownstname localhost

我正在使用Cygwin在Windows764位上安装Hadoop。成功格式化Hadoop后,我想使用以下命令启动它:启动-dfs.sh。但它报告为:$sbin/start-dfs.sh17/03/2617:35:27WARNutil.NativeCodeLoader:Unabletoloadnative-hadooplibraryforyourplatform...usingbuiltin-javaclasseswhereapplicable]tartingnamenodeson[localhost:Nameorservicenotknownstnamelocalhostalwang@

hadoop - 如何找到自动终止的 hive mapreduce 作业的原因

我已经执行了配置单元查询,它被自动杀死了(不是任何人手动)我无法在任何日志中找到原因。Cloudera版本:5.4.11hive:1.1.0我在下面的链接中看到了类似的问题,但没有成功Whywasahivemapreducejobkilled? 最佳答案 在这里查看您的工作历史:http://:19888/jobhistory​ 关于hadoop-如何找到自动终止的hivemapreduce作业的原因,我们在StackOverflow上找到一个类似的问题: h

java - 创建 mapreduce Web 应用程序的方法

我想创建一个网站,我将使用(Hadoopmapreduce)实现网站的一部分。我开始在我的操作系统(MacOS)上使用带有maven插件的Eclipse。我开始使用apachemaven编写我的代码。“我仍然没有实现该网站”。我的问题是Maven是否与机器集群一起运行?关于如何创建部分在mapreduce中运行的网站的任何建议?请帮忙谢谢大家 最佳答案 ApaheMaven不是“运行我们代码的东西”。它实际上是一个构建工具:ApacheMaven是一个软件项目管理和理解工具。(https://maven.apache.org/)。您

java - MapReduce 作业失败——线程中的异常 "main"java.io.IOException : java.net.ConnectException

我正在Hadoop上运行一个简单的计数程序。我的输入文件大小为4GB。由于某种原因,作业不断失败并出现错误:但是,如果我用一个小的输入文件(比如100MB)尝试相同的代码,它工作得很好。我是新手,我似乎找不到任何可行的解决方案。我的设置是伪分布式。我需要进行任何配置更改吗?我已经按照hadoop文档提供的Psuedo分布式设置进行了标准配置。我们将不胜感激任何帮助。 最佳答案 根据您发布的错误堆栈跟踪,ConnectionRefused异常是针对JobHistoryServer的。对于伪分布式设置,无需更改配置即可启动JobHist

java - Mapreduce 作业吐出 java.io.IOException : com. mysql.jdbc.Driver

hadoop-2.7.3我正在创建一个mapreduce作业,它从HDFS输入文件读取数据并将数据写入mysql。它在启动连接时抛出错误。没有其他信息,例如连接被拒绝或classNotFound异常。简单的IO异常,对我来说没有任何意义。Error:java.io.IOException:com.mysql.jdbc.Driveratorg.apache.hadoop.mapreduce.lib.db.DBOutputFormat.getRecordWriter(DBOutputFormat.java:185)atorg.apache.hadoop.mapred.ReduceTask$

python - 输入记录与 python mapreduce 中的输出记录不匹配

我正在用python编写一个mapreduce程序。当我使用-运行它时,映射器工作得很好catinput.csv|pythonmapper.py>output.tsv但是当我使用下面的命令运行它时,我没有得到想要的输出-nohuphadoopjar/opt/mapr/hadoop/hadoop-2.7.0/share/hadoop/tools/lib/hadoop-streaming-2.7.0-mapr-1607.jar-Dmapreduce.job.queuename=queue_name-Dmapred.map.tasks=1000-Dmapred.reduce.tasks=0-

java - 在 MapReduce 中读取文件的问题

在使用hadoop1.1.2的mapreduce作业中,我一直无法从文件中读取其路径由用户提供的内容。下面的代码是我一直在尝试使用的代码,但是在读取文件内容时,我总是得到null。我在这里遇到了一些解决方案,但没有一个对我有用:主要功能:Jobjob=newJob(conf,"FindK-NearestNeighbour");job.setJarByClass(Knn.class);DistributedCache.addCacheFile(newPath("knnParamFile").toUri(),con);映射器类(设置函数):Configurationconf=context

scala - 使用 Scala 的 Mapreduce 程序

我正在尝试运行一个用scala编写的mapreduce程序。我在类路径中包含了scala-library。运行程序时,我的程序抛出以下错误。$hadoopjar~/HadoopScala.jarcom.learning.spark.WordCount/input/wordcountinput.csv/output-libjars~/lib/org.scala-lang.scala-library_2.12.2.v20170412-161608-VFINAL-21d12e9.jarExceptioninthread"main"java.lang.NoClassDefFoundError: