草庐IT

logical_not

全部标签

hadoop - 如何解决 pig 中的 "Error during parsing. could not instantiate"?

大家好,我是Pig的新手,我正在尝试遵循Pig脚本:然后它显示以下错误:ERROR1000:解析时出错。无法使用参数“null”实例化“UPER”详细信息位于日志文件:/home/training/pig_1371303109105.log我的Pig脚本:registerudf.jar;A=LOAD'data1.txt'USINGPigStorage(',')AS(name:chararray,class:chararray,age:int);B=foreachAgenerateUPER(class);我关注this教程。我的java类是:entercodehereimportorg.

Hadoop distcp 从 S3 复制 : Signature does not match error

我正在尝试将文件从S3复制到我在AmazonEC2上的hadoopHDFS。我使用的命令是:bin/hadoopdistcps3://:@/f1hdfs://user/root/f1是文件名我也将它更改为s3n以查看它是否有效,但它没有。我将secret访问key中的正斜杠替换为%2F我得到的错误是:SignatureDoesNotMatchorg.jets3t.service.S3ServiceException:S3GETfailedfor'/%2Ff1'Therequestsignaturewecalculateddoesnotmatchthesignatureyouprovid

java - 使用 -libjars 的 MapReduce 流作业,自定义分区程序失败 : "class not found"

我正在尝试将自定义(java)分区程序附加到我的MapReduce流作业。我正在使用这个命令:../bin/hadoopjar../contrib/streaming/hadoop-streaming-1.2.1.jar\-libjars./NumericPartitioner.jar-Dmapred.map.tasks=12-Dmapred.reduce.tasks=36\-input/input-output/output/keys-mapper"map_threeJoin.py"-reducer"keycount.py"\-partitionernewjoin.NumericPa

python - mongodb_hadoop 流与 python : -inputURI not recognized

我正在尝试使用mongodb_hadoop连接器在python中创建一个MapReduce应用程序。我有一个安装了hadoop2.2.0的集群。我已经安装了mongodb_hadoop连接器v1.3.0。我已经安装了mongodb并创建了一个名为hadoop_db的测试数据库,其中包含一个名为“整数”的集合,其中包含整数值。我的目标是尝试计算每个整数的出现次数。我的工作基于此presentation但是当我尝试执行作业时,这是我得到的:bin/hadoopjarshare/hadoop/tools/lib/hadoop-streaming-2.2.0.jar\-mapperpyhado

Hadoop:格式化名称节点时出错 - 'Could not find or load main class namenodes'

在我安装了上传hadoop所需的一切之后(win-7-64位上的unix),我得到了这个错误(粗体):roeygol@roeygol-PC/etc/hadoop-2.5.1/bin$./hdfsnamenodes-formatError:Couldnotfindorloadmainclassnamenodes我按要求定义了所需的节点和所有其他配置,我该如何解决这个问题? 最佳答案 hdfsnamenode-formatits"namenode"not"namenodes" 关于Hadoo

java - 错误 : JAVA_HOME is not set and could not be found after hadoop installation

在干净的RaspbianStretchLite(加上Java版本1.8.0_65)上的RaspberryPi上以独立模式安装hadoop2.7.7后,出现以下错误:Error:JAVA_HOMEisnotsetandcouldnotbefound.尽管我在/etc/bash.bashrc中有这一行:exportJAVA_HOME=$(readlink-f/usr/bin/java|sed"s:bin/java::")printenv输出如下:...JAVA_HOME=/usr/lib/jvm/jdk-8-oracle-arm32-vfp-hflt/....我看到很多similarque

hadoop - mapreduce 程序 : Reducer is not getting called

我知道在这里问这个问题是非常愚蠢的。可能是我的眼睛不好或什么的。我无法理解为什么我的reducer没有被调用,即使我已经在驱动程序类中配置了它。请帮助我确定我错过了什么的确切位置。我的司机类(class)publicclassDPDriver{publicstaticvoidmain(String[]args)throwsIOException,InterruptedException,ClassNotFoundException{Configurationconfig=newConfiguration();config.set("mapred.textoutputformat.sep

java - 错误: JAVA_HOME is not set and could not be found. 如何在Hadoop中永久设置JAVA_HOME?

我安装了CDHinPseudodistributedmode在Ubuntu12.04上。在此之前,我安装了Java并将我的JAVA_HOME变量导出到/usr/lib/jvm/java-6-oracle并导出了JAVA_HOME到path,对于root用户和其他用户(自己,hdfs)。它被正确地回显并显示在env结果中。我的CDH安装仍然提示JAVA_HOMEnotfound/set所以我根据this添加JAVA_HOME到/etc/environment以及/etc/sudoers中的条目Defaultsenv_keep+=JAVA_HOME一切正常,我可以通过Jps检查服务是否正在

oracle - 使用 Spark 查询 Oracle DB 时出现 "ORA-00933: SQL command not properly ended"错误

我尝试使用Spark数据源API从Oracle数据库加载数据。因为我需要通过查询加载数据,所以我使用了下面的查询,这是我从网上的一些例子中整理出来的:Mapoptions=newHashMap();options.put("driver",MYSQL_DRIVER);options.put("user",MYSQL_USERNAME);options.put("password",MYSQL_PWD);options.put("url",MYSQL_CONNECTION_URL);options.put("dbtable","(selectemp_no,emp_idfromemploy

xml - Hadoop单节点安装-格式化错误-Content is not allowed in prolog

我正在尝试进行hadoop单节点安装。我正在关注this有关hadoop安装说明的文章。我需要做的步骤之一是使用命令格式化hadoop文件系统hduser@dbserver:~/hadoop/conf$/home/hduser/hadoop/bin/hadoopnamenode-formathduser@dbserver:~/hadoop/conf$/home/hduser/hadoop/bin/hadoopnamenode-format12/02/0618:24:31INFOnamenode.NameNode:STARTUP_MSG:/************************