草庐IT

hadoop - oozie 在通过协调器提交作业时模拟了哪个用户

用户模拟/传播在oozie中如何工作? 最佳答案 检查UserPropogation来自Oozie文档。它说Whensubmittingaworkflowjob,theconfigurationmustcontainauser.nameproperty当您没有明确添加此属性时,它会分配给提交作业的用户。 关于hadoop-oozie在通过协调器提交作业时模拟了哪个用户,我们在StackOverflow上找到一个类似的问题: https://stackoverf

hadoop - 将 Pig 与 Hbase 集成

我在linux上安装了hadoop-2.5.0、pig0.13.0和HBase0.98.6.1。尝试运行简单的pig脚本时,出现错误2014-10-1416:01:54,891[main]ERRORorg.apache.pig.tools.grunt.Grunt-ERROR2998:Unhandledinternalerror.org.apache.hadoop.hbase.util.Bytes.equals([BLjava/nio/ByteBuffer;)ZDetailsatlogfile:/home/labuser/pig_1413279561970.log粘贴下面的日志...Pi

hadoop - 如果 2 个映射器输出相同的键,reducer 的输入是什么?

我在学习Mapreduce的过程中有以下疑惑。如果有人能回答,将会有很大的帮助。我有两个映射器处理同一个文件-我使用MultipleInputFormat配置它们映射器1-预期输出[提取文件的几列之后]a-1234b-3456c-1345映射器2预期输出[提取同一文件的几列后]a-Mondayb-Tuesdayc-Wednesday还有一个reducer函数,它只输出它作为输入获得的键值对所以我希望输出是我所知道的,相似的键将被洗牌以制作一个列表。a-[1234,Monday]b-[3456,Tuesday]c-[1345,Wednesday]但是我得到了一些奇怪的输出。我猜只有1个M

hadoop - 如何防止将空 Avro 文件提交到 HDFS?

我的工作是在HDFS中创建一个Avro文件,并在该文件中附加数据。然而,偶尔不会有任何数据追加,在这种情况下我不希望应用程序刷新并关闭文件,而是应该检查文件是否为空(但我假设Avro模式将被写入header所以技术上不是一个空文件)并删除该文件,如果它是空的。这对Avro+HDFS库可行吗? 最佳答案 尝试使用LazyOutputFormat在指定作业的输出格式时。它延迟创建输出,这意味着只有在输出存在时才会创建输出文件。所以不要写这样的东西:job.setOutputFormatClass(TextOutputFormat.cla

r - 不同平台上 PMML 模型的评分差异

我在R中构建了一个玩具随机森林模型(使用caret包中的GermanCredit数据集),将其导出到PMML4.0并使用CascadingPattern库部署到Hadoop。我遇到了一个问题,即CascadingPattern对相同数据的评分(在二元分类问题中)与R中的相同模型不同。在200次观察中,有2次的得分不同。这是为什么?会不会是随机森林的实现方式不同? 最佳答案 GermanCredit数据集代表一个分类类型的问题。分类型RF模型的获胜分数只是成员决策树中最常见的类标签。假设您的RF模型包含100棵决策树,其中50棵决策树

hadoop - 使用Hadoop Map reduce处理和拆分大数据?

我在文本文件中有大量数据(1,000,000行)。每行有128列。现在我正在尝试用这个大数据构建一个kd树。我想使用mapreduce进行计算。针对我的问题的蛮力方法:1)编写一个mapreduce作业来查找每一列的方差并选择方差最高的列2)将(列名,方差值)作为输入编写另一个mapreduce作业将输入数据分成两部分。对于给定的列名,第1部分包含所有值小于输入值的行,第二部分包含大于输入值的所有行。3)对于每个部分重复步骤1和步骤2,继续该过程,直到每个部分剩下500个值。列名称、方差值构成我的树的单个节点。因此,对于高度为10的树,我需要使用蛮力方法运行1024个mapreduce

hadoop - 外部表到 Hive 中的文件?

是否可以将LOCATION中的文件用于HIVE中的外部表?CREATEEXTERNALTABLEtable1(linestring)LOCATION'/hdp_in/fd/file.txt.gz';因为我得到一个错误:FAILED:ExecutionError,returncode1fromorg.apache.hadoop.hive.ql.exec.DDLTask.MetaException(message:Gotexception:org.apache.hadoop.fs.FileAlreadyExistsExceptionParentpathisnotadirectory:/hd

python - 根据子字符串在日志文件中查找特定行 - Python

我有以下一blockHadoop集群:==>namenode_32:14/11/0202:19:32INFOnamenode.NNStorage:Storagedirectory/data/1/dfs/nnhasbeensuccessfullyformatted.==>namenode_32:14/11/0202:19:32INFOnamenode.NNStorage:Storagedirectory/nfsmount/dfs/nnhasbeensuccessfullyformatted.==>namenode_32:14/11/0202:19:32INFOnamenode.FSIma

json - 将 JSON 数组加载到 Pig 中

我有一个格式如下的json文件[{"id":2,"createdBy":0,"status":0,"utcTime":"Oct14,20144:49:47PM","placeName":"21/F,CunninghamMainRd,SampangiRamaNagarBengaluruKarnatakaIndia","longitude":77.5983817,"latitude":12.9832418,"createdDate":"Sep16,20142:59:03PM","accuracy":5,"loginType":1,"mobileNo":"0000005567"},{"id"

Java编译不产生.jar

我已经创建了简单的“WordCount.java”文件来实现一个简单的hadoop程序,并且在编译时,它不会创建一个.jar文件。在WordCount.class、WordCount$Map.class和WordCount$Reduce.class中创建的文件。我查看了WordCount.java文件,它确实包含一个publicstaticvoidmain(String[]args)例程,所以它应该创建一个.jar文件,对吧?这是我很长一段时间以来第一次接触Java,因此很容易在Java的编译方式上出错,但是给定以下代码,它不应该在正确编译后给我一个.jar文件吗?packageorg