草庐IT

appengine-mapreduce

全部标签

hadoop - java.lang.Exception : java. lang.IncompatibleClassChangeError : Found interface org. apache.hadoop.mapreduce.TaskAttemptContext,但类是预期的

我在使用Hadoop2.4.0和Nutch2.2时遇到了这个异常。当我尝试运行这个命令时:./hadoopjarapache-nutch-2.2.1.joborg.apache.nutch.crawl.Crawlerurls-solr//:8983-depth2我得到:Java.lang.Exception:java.lang.IncompatibleClassChangeError:Foundinterfaceorg.apache.hadoop.mapreduce.TaskAttemptContext,butclasswasexpectedatorg.apache.hadoop.ma

java - mapreduce.reduce.shuffle.memory.limit.percent、mapreduce.reduce.shuffle.input.buffer.percent 和 mapreduce.reduce.shuffle.merge.percent

我只是想验证我对这些参数及其关系的理解,如果我错了请通知我。mapreduce.reduce.shuffle.input.buffer.percent告诉分配给reducer的整个洗牌阶段的内存总量。mapreduce.reduce.shuffle.memory.limit.percent告诉单个shuffle可以从mapreduce.reduce.shuffle.input消耗的内存限制的最大百分比.buffer.percent.mapreduce.reduce.shuffle.merge.percent是启动内存中合并的使用阈值,表示为总内存的百分比(mapreduce.reduc

hadoop - 使用 TableMapper 时 HBase Mapreduce 依赖问题

我正在使用CDH5.3,我正在尝试编写一个mapreduce程序来扫描表并进行一些处理。我创建了一个扩展TableMapper的映射器,我得到的异常是:java.io.FileNotFoundException:Filedoesnotexist:hdfs://localhost:54310/usr/local/hadoop-2.5-cdh-3.0/share/hadoop/common/lib/protobuf-java-2.5.0.jaratorg.apache.hadoop.hdfs.DistributedFileSystem$17.doCall(DistributedFileSy

python - 为什么使用 python 的 hadoop mapReduce 失败但脚本在命令行上运行?

我正在尝试使用Cloudera5.5.0实现一个简单的Hadoopmapreduce示例map&reduce步骤应该使用Python2.6.6实现问题:如果脚本是在unix命令行上执行的,它们工作得非常好并产生预期的输出。猫加入2*.txt|./join3_mapper.py|排序|./join3_reducer.py但是将脚本作为hadoop任务执行非常失败:hadoopjar/usr/lib/hadoop-mapreduce/hadoop-streaming.jar-input/user/cloudera/inputTV/join2_gen*.txt-output/user/clo

python - 深度学习 : is there any open-source library that can be integrated with Hadoop streaming and MapReduce?

关闭。这个问题不符合StackOverflowguidelines.它目前不接受答案。我们不允许提问寻求书籍、工具、软件库等的推荐。您可以编辑问题,以便用事实和引用来回答。关闭6年前。Improvethisquestion谷歌搜索弹出了不少开源深度学习框架。这是一个收集列表GoogleTensorFlowTheanomxnetkerasPylearn2BlocksLasagnechainerscikit-neuralnetworktheano-lightsdeepyidlfreinforce.jsopendeepmxnet.jsCGTTorchCaffescikit-cudacuda4

java - Accumulo MapReduce 作业因 java.io.EOFException 而失败,使用 AccumuloRowInputFormat

我所有的映射器都失败了,除了下面的异常(exception)。为了简洁起见,我只展示了最后一次失败。为什么会发生这种情况,我该如何解决?16/09/2117:01:57INFOmapred.JobClient:TaskId:attempt_201609151451_0044_m_000002_2,Status:FAILEDjava.io.EOFExceptionatjava.io.DataInputStream.readFully(DataInputStream.java:197)atjava.io.DataInputStream.readUTF(DataInputStream.jav

java - 链接两个作业时 hadoop.mapreduce.lib.input.FileInputFormat.getBlockIndex 中的 NullPointerException

我正在尝试构建倒排索引。我链接了两个作业。基本上,第一个作业解析输入并对其进行清理,并将结果存储在文件夹“output”中,该文件夹是第二个作业的输入文件夹。第二个工作应该实际构建倒排索引。当我刚找到第一份工作时,它工作得很好(至少,没有异常(exception))。我像这样链接两个作业:publicclassMain{publicstaticvoidmain(String[]args)throwsException{StringinputPath=args[0];StringoutputPath=args[1];StringstopWordsPath=args[2];Stringfi

eclipse - 如何干净地卸载 Eclipse MapReduce 插件?

我正在尝试让用于hadoop开发的eclipse插件正常工作,我使用的是hadoop0.18.3。我在Eclipsev3.5.2(M20100211-1343)上安装了旧的MapReduce插件(http://www.alphaworks.ibm.com/tech/mapreducetools),方法是将其复制到/Applications/eclipse/plugins并重新启动eclipse,但这没有用,我认为这是因为它是为旧版本的hadoop和eclipse(大约2007年)。然后我意识到hadoop发行版在contrib/eclipse-plugin下有一个jar-所以将其复制到

hadoop - 从 MapReduce 作业向 Hive 添加分区

我是Hive和MapReduce的新手,非常感谢您的回答并提供正确的方法。我在hive中定义了一个外部表logs,在日期和源服务器上分区,外部位置在hdfs/data/logs/上。我有一个MapReduce作业,它获取这些日志文件并将它们拆分并存储在上述文件夹下。喜欢"/data/logs/dt=2012-10-01/server01/""/data/logs/dt=2012-10-01/server02/"......在MapReduce作业中,我想将分区添加到Hive中的表日志中。我知道这两种方法altertable命令--太多的altertable命令添加动态分区对于方法二,我

hadoop - Amazon Elastic MapReduce 引导操作不工作

我已经尝试了以下引导操作组合来增加我的作业的堆大小,但它们似乎都不起作用:--mapred-key-valuemapred.child.java.opts=-Xmx1024m--mapred-key-valuemapred.child.ulimit=unlimited--mapred-key-valuemapred.map.child.java.opts=-Xmx1024m--mapred-key-valuemapred.map.child.ulimit=unlimited-mmapred.map.child.java.opts=-Xmx1024m-mmapred.map.child.