草庐IT

Mic-Input

全部标签

Java Hadoop : How can I create mappers that take as input files and give an output which is the number of lines in each file?

我是Hadoop的新手,我已经设法运行了wordCount示例:http://hadoop.apache.org/common/docs/r0.18.2/mapred_tutorial.html假设我们有一个包含3个文件的文件夹。我希望每个文件都有一个映射器,这个映射器将只计算行数并将其返回给缩减器。然后,reducer会将每个映射器的行数作为输入,并将所有3个文件中存在的总行数作为输出。所以如果我们有以下3个文件input1.txtinput2.txtinput3.txt映射器返回:mapper1->[input1.txt,3]mapper2->[input2.txt,4]mappe

hadoop - 星火-Hadoop-> org.apache.hadoop.mapred.InvalidInputException : Input path does not exist

我在尝试将文件从hdfs读取到Spark时遇到错误。文件README.md存在于hdfs中spark@osboxeshadoop]$hdfsdfs-lsREADME.md16/02/2600:29:14WARNutil.NativeCodeLoader:Unabletoloadnative-hadooplibraryforyourplatform...usingbuiltin-javaclasseswhereapplicable-rw-r--r--1sparksupergroup48112016-02-2523:38README.md在Sparkshell中,我给了scala>valr

java - 亚马逊电子病历 : running Custom Jar with input and output from S3

我正在尝试运行具有自定义jar步骤的EMR集群。该程序从S3获取输入并输出到S3(或者至少这是我想要完成的)。在步骤配置中,我在参数字段中有以下内容:v3.MaxTemperatureDrivers3n://hadoopbook/ncdc/alls3n://hadoop-szhu/max-temp其中hadoopbook/ncdc/all是包含输入数据的存储桶的路径(作为旁注,我正在运行的示例来自此book),并且hadoop-szhu是我自己的存储桶,我想在其中存储输出。按照这个post,我的MapReduce驱动程序如下所示:packagev3;importorg.apache.h

hadoop - ambari hadoop 安装期间权限被拒绝(publickey、gssapi-keyex、gssapi-with-mic、密码)

我正在尝试使用ambari部署hadoop集群,但是当我使用FQDN选择主机名并继续配置时,我收到了ssh的权限被拒绝错误。步骤:1.以root身份使用ssh-keygen生成rsakey。更改了.ssh(700)和authorized_keys(640)的权限将公钥分类为authorized_keys。并将公钥复制到所有主机(authorized_keys)并如上所述更改文件权限。我可以从ambari服务器主机到所有其他主机的无密码ssh。但是来自ambari的hadoop安装失败并出现以下错误。SSHcommandexecutionfinishedhost=XXX,exitcode

Hadoop Mapreduce 错误输入路径不存在 : hdfs://localhost:54310/user/hduser/input"

我已经在UbuntuLinux15.04中安装了hadoop2.6,并且运行良好。但是,当我运行示例测试mapreduce程序时,出现以下错误:org.apache.hadoop.mapreduce.lib.input.InvalidInputException:Inputpathdoesnotexist:hdfs://localhost:54310/user/hduser/input.请帮助我。以下是错误的完整详细信息。hduser@krishadoop:/usr/local/hadoop/sbin$hadoopjar/usr/local/hadoop/share/hadoop/ma

hadoop - 绕过 org.apache.hadoop.mapred.InvalidInputException : Input Pattern s3n://[. ..] 匹配 0 个文件

这是我的一个问题alreadyasked在spark用户邮件列表上,我希望在这里取得更大的成功。我不确定它是否与spark直接相关,尽管spark与我无法轻易解决该问题的事实有关。我正在尝试使用各种模式从S3获取一些文件。我的问题是其中一些模式可能什么都不返回,当它们返回时,我得到以下异常:org.apache.hadoop.mapred.InvalidInputException:InputPatterns3n://bucket/mypatternmatches0filesatorg.apache.hadoop.mapred.FileInputFormat.listStatus(Fi

file - Hadoop MapReduce : Appropriate input files size?

我有3位数GB甚至1或2位数TB的数据集。因此,输入文件是一个文件列表,每个文件的大小约为10GB。我在hadoop中的mapreduce作业处理所有这些文件,然后只给出一个输出文件(带有聚合信息)。我的问题是:从Apache调整hadoop/mapreduce框架的合适文件大小是多少?我听说大文件比小文件更受欢迎。有什么想法吗?我唯一确定的是hadoop读取block,每个block默认为64MB。所以如果文件大小是64MB的倍数就好了。目前,我的应用程序只将输出文件写入一个文件。文件大小当然是3位千兆位。我想知道如何有效地对文件进行分区。当然,我可以只使用一些unix工具来完成这项

hadoop - 第一个hadoop项目报错: "Input path does not exist"

要设置一个简单的hadoop项目,我将按照本教程进行操作:http://ebiquity.umbc.edu/Tutorials/Hadoop/23%20-%20create%20the%20project.html我的hadoop单节点似乎运行正常。当我使用此代码指定In文件夹时:FileInputFormat.setInputPaths(conf,newPath("In"));我收到这个错误:13/03/0322:05:27ERRORsecurity.UserGroupInformation:PriviledgedActionExceptionas:DEVUSERcause:org.

php - CakePHP - 为 Form->input : I want to have a line break, 设置默认值但是如何设置?

我有一个表单输入,我想将其默认值作为几个短段落。例如在我看来:echo$this->Form->input('story',array('default'=>'Thanksforvisitingmycampaignpage.Besuretocheckoutthelinksbelow'));目前一切正常,并创建了一个包含这两个句子的文本框,但我更愿意将它们放在不同的两行中。并且还保存在数据库中,因此当它们被召回时,它们会自动出现在两个段落中。我试过了标签等,但它们只是出现在文本中。在View中设置默认值时是否有一些方法可以创建换行符,该默认值将作为换行符等存储在数据库中...?

php - 使用 $input->all() 而不是 Input::all() Laravel-5

我正在尝试在Laravel-5中使用$input->all()而不是Input::all(),但它似乎没有喜欢它,即使我将输入引用传递给函数,如下所示:/***Searchforaspecifiedresource.**@returnResponse*/publicfunctionsearch(Booking$booking,Input$input){dd($input->all());//thisdoesn'tworkdd(Input::all());//thisDOESwork}我得到的错误是:调用未定义的方法Illuminate\Support\Facades\Input::al