我想使用MapReduce来获取txt文件中每一年的最大值和最小值。文件中的内容如下所示： 1979 23 23 2 43 24 25 26 26 26 26 25 261981 31我希望MapReduce给我一个最终的输出，如下所示： 1979 2, 26...reduce 0%
19/04/10 16:59:24 WARN mapred
浏览 26提问于2019-04-10得票数 1
回答已采纳
当我设置mapreduce.task.io.sort.mb = 100000时。我得到了以下异常。java.lang.Exception: java.io.IOException: Invalid "mapreduce.task.io.sort.mb": 100000
mapreduce.task.io.sort.mb的最大值是多少？
浏览 2提问于2014-05-02得票数 7
我正在尝试使用简单的过滤器来获取Raik对象。在将对象存储到桶之前，我已经启用了对其的搜索，并尝试如下：
MapReduceResult结果= riakClient。mapReduce("serviceProvider"，“name:oved1 1”)。(MapReduce.java:80)：com.basho.riak.client.RiakException: java.io.IOException：{“错误”：“map_reduce_error”(HTTPClientAdapt
浏览 3提问于2012-08-12得票数 0
回答已采纳
override def setup(context: Context) { }现在的实际问题是： public static class Mapper<KEYIN, VALUEIN,<KEYIN,VALUEIN,KEYOUT,VALUEOUT>.Context c
浏览 4提问于2010-07-25得票数 5
回答已采纳
2回答
我很好奇mapreduce作业是否在一台机器中使用多个线程。例如，我在hadoop集群中有10个服务器，默认情况下，如果输入文件足够大，就会有10个映射器。单个映射器是否在一台机器中使用多个线程？
浏览 6提问于2016-10-06得票数 4
回答已采纳
我是Hadoop的新手，但已经阅读了雅虎关于这方面的教程，并且已经编写了一些mapReduce作业。我以前的所有作品都使用TextInputFormat，但现在我需要将其更改为KeyValueInputFormat。问题是在Hadoop0.20.2中找不到KeyValueInputFormat.class？我在下面附上我的代码(这是一个字数统计的例子，只是改变了输入格式)i
浏览 1提问于2012-07-12得票数 0
回答已采纳
输出目录如下所示：/hdfs/base/dir/notmatched/YYYY/MM/DDFileOutputFormat.setOutputPath(job, new Path("/hdfs
浏览 4提问于2015-04-08得票数 1
回答已采纳
2回答
我有一个映射-减少作业，其中的键是数字从1-200。我的预期输出是按数字顺序的( number，value)。但我得到的输出如下：10 value :2 value :3 value
我知道这是因为Map的默认行为-减少按升序排序键。我只想把我的钥匙按数字排序。我怎样才能做到这一点？
浏览 6提问于2015-03-06得票数 0
回答已采纳
我正尝试在本地机器上运行以下MapReduce代码：[main] ERROR UserGroupInformation - PriviledgedActionExceptionas:jeffy (auth:SIMPLE) cause:java.io.IOException: java.util.concurrent.ExecutionException: java.io.IOExceptionException in thread "main" java.io.
浏览 2提问于2014-05-28得票数 2
我从下载了VM
我发现下面列出的服务都是在系统启动后运行的。，上面使用的是MRv2纱线框架。:39 ERROR security.UserGroupInformation: PriviledgedActionException as:cloudera (auth:SIMPLE) cause:java.io.IOExceptionPlease check your configuration for mapreduce.framework.name and the correspond server add
浏览 3提问于2012-10-11得票数 10
我将大量文件导入到HBase表中，因此我决定使用批量加载。我已经设法通过MapReduce作业准备了数据，但是当我尝试使用以下命令完成加载时Exception in thread "main" java.io.IOException: Trying to load(LoadIncrementalHFiles.
浏览 0提问于2014-07-25得票数 3
import java.io.IOException;
import org.apache.hadoop.fs.Path;import org.apache.hadoop.mapreduce.Reducer;上面是导入<e
浏览 1提问于2016-10-08得票数 0
2回答
在设置历史服务器和单元服务器时，webHDFS在REST中给出了以下错误。curl -sS -L -w '%{http_code}' -X PUT -T /usr/hdp/2.3.4.0-3485/hadoop/mapreduce.tar.gz 'http://ambari1.devcloud.247-inc.net:50070/webhdfs/v1/hdp/apps/2.3.4.0-3485/<em
浏览 2提问于2016-01-25得票数 0
在我的项目中，我必须读取抛出MapReduce的镶木地板文件。有很多小尺寸的实木地板文件。我需要一些组合拼花输入格式，可以组合小文件根据分割大小，使映射器的数量将会更少。请让我知道，如果有一些实用程序或任何简单的方法来做到这一点。
谢谢
浏览 1提问于2016-01-18得票数 0
/hadoop-mapreduce-examples-0.23.0-cdh4b1.jar grep *.xml /user/out/ 'dfs'
12/04/10 19:23:15 INFO mapreduce.Cluster15 ERROR security.UserGroupInformation: PriviledgedActionException as:anchauhan (auth:SIMPLE) cause:java.io.IOException</em
浏览 1提问于2012-04-11得票数 3
回答已采纳
SparkContext textFile似乎只希望文件出现在给定的目录位置？？它也不需要文件。
<!这种行为令人困惑--考虑到处理目录的适当支持似乎已经到位。
浏览 8提问于2015-03-02得票数 19
回答已采纳
getInputFormat() throws java.io.IOException;
现在，上面的format org.apache.hadoop.mapreduce.InputFormat是新的API，所以我必须通过扩展org.apache.hadoop.mapreduce.InputFormat来创建自定义文件格式。我已经使用新的API创建了自定义文件格式，但我需要使用以下代码弄清楚拆分主机的详细信息。中可用，但在org.apache.hadoop.ma
浏览 0提问于2015-01-05得票数 0
我想在hbase中加载这个文本使用相同的程序，有没有办法做it.Any帮助将是值得欣赏的package com.tcs;
}package com.tcs;
import org.apach
浏览 0提问于2017-06-12得票数 0
我试图在维基百科转储文件上执行地图缩减过程，我读到hadoop可以神奇地解压缩文件，并将其拆分为映射器上的进程。有人能帮我吗？编辑import java.io.IOException;
import org
浏览 0提问于2017-03-26得票数 0
我在eclipse中运行这个--露娜。当我执行时，map和reduce都显示它们是100%完成的。但是我没有得到输出。相反，我在最后得到了下面的错误。15/03/20 11:29:44 ERROR security.UserGroupInformation: PriviledgedActionException as:hduser cause:java.io.IOException: No input paths specified in job
Exception in thread "main"
浏览 0提问于2015-03-20得票数 0
云服务器
ICP备案
对象存储
云点播
即时通信 IM
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号