草庐IT

common_runtime

全部标签

hadoop - 使用 Java Runtime.exec() 在 Hadoop 上运行命令

有一个名为“cufflinks”的程序运行如下:cufflinks-o此程序将1个文件作为输入,并在“output-dir”中生成4个文件作为输出。我正在尝试使用映射器类中的Runtime.exec()在Hadoop集群上运行相同的程序。我在设置output-dir=/some/path/on/HDFS我原以为这4个文件将作为o/p在HDFS上生成。然而,事实并非如此,HDFS上的o/p目录不包含这4个文件中的任何一个。然后我尝试设置output-dir=/tmp/output/它奏效了。谁能建议为什么它不能在HDFS上运行?我需要做什么才能让它在HDFS上运行?谢谢。

java - NoClassDefFoundError : org/apache/commons/lang/StringUtils

我正在编写mapreduce程序来比较两个文件。当我运行该程序时,它抛出以下异常。Exceptioninthread"main"java.lang.NoClassDefFoundError:org/apache/commons/lang/StringUtilsatorg.apache.hadoop.metrics2.lib.MutableMetricsFactory.getName(MutableMetricsFactory.java:119)我的pom文件。org.apache.hadoophadoop-core0.20.2org.apache.hadoophadoop-mapred

hadoop - 从SVN “no namenode to stop”通过Hadoop替换mapred/hdfs/common jar构建后

我从中checkout源代码http://svn.apache.org/repos/asf/hadoop/commonhttp://svn.apache.org/repos/asf/hadoop/hdfshttp://svn.apache.org/repos/asf/hadoop/mapreduce并得到hadoop-mapred-0.23.0-SNAPSHOT.jarhadoop-hdfs-0.23.0-SNAPSHOT.jarhadoop-common-0.23.0-SNAPSHOT.jar但是我无法使用这些jar启动all.sh...Jobtracker和tasktracker启

java - 如何更改 org.apache.commons.logging.Log.info ("massage") 将写入日志文件

我正在java平台上开发hadoop的开源。我添加了类(在yarntimelineserver中)除了打印信息,还做各种事情,我用两个库写信息importorg.apache.commons.logging.Log;importorg.apache.commons.logging.LogFactory;示例:privatestaticfinalLogLOG=LogFactory.getLog(IntermediateHistoryStore.class);LOG.info("massage");为了查看我的更改,我通过hadoop的cmd或通过任务管理器运行时间线服务:**C:\hdp

hadoop - 错误 : java. lang.ClassNotFoundException : org. apache.commons.collections4.map.LinkedMap

执行命令时出错:hadoopjar/home/edureka/Desktop/firstnlast.jarFirstandLasthdfs:/FirstnLast/first-last_samplehdfs:/FirstnLastoutput代码如下:importjava.io.IOException;/*importjava.util.ArrayList;importjava.util.Iterator;importjava.util.StringTokenizer;*/importorg.apache.commons.collections4.map.LinkedMap;impor

hadoop - Pig HCatLoader java.lang.String 无法转换为 org.apache.hadoop.hive.common.type.HiveVarchar

我有下面的外部配置单元表,稍后我将使用它进行处理。CREATEEXTERNALTABLEhive_test_table(cmp_dteDATE,my_indCHAR(1),typ_descVARCHAR(40),def_typ_descVARCHAR(60),tt_indCHAR(1),nn_nmVARCHAR(80),xzs_descVARCHAR(60),pqa_descVARCHAR(40),aac_cntINT,pqdd_cntINT,nnc_cntINT,ors_amtDECIMAL(18,2),rddd_amtDECIMAL(18,2),btdff_idBIGINT,fil

macos - 错误:/usr/local/Cellar/sqoop/1. 4.6/../hadoop不存在!请将 $HADOOP_COMMON_HOME 设置为 Hadoop 安装的根目录

我在Mac上使用brew安装了Hadoop,然后进行了配置。然后我安装了Sqoop,当我尝试运行Sqoop时出现以下错误:错误:/usr/local/Cellar/sqoop/1.4.6/../hadoop不存在!请将$HADOOP_COMMON_HOME设置为Hadoop安装的根目录。我的Hadoop运行良好,我什至在~/.bash_profile和sqoop-env.sh中都设置了HADOOP_COMMON_HOME的路径这是我的sqoop环境文件:#LicensedtotheApacheSoftwareFoundation(ASF)underoneormore#contribut

hadoop - Nutch 2.3 在 runtime/lib 文件夹中有一个旧版本的 hbase jar

Nutch2.3在runtime/lib文件夹中有一个旧版本的hbasejar文件(hbase-0.94.14.jar)。我已经下载了hbase0.94.14但它没有启动,因为“服务器IPC版本9无法与客户端版本4通信”。我可以运行Hbase1.1.2,但不包含jar文件。我该如何解决这个问题?谢谢 最佳答案 您不能仅通过替换jars/bindings来解决它。问题在于使用与HBase1.0+版本不兼容的pre-1.0客户端的Gora。您现在的选择是更新Gora(不仅仅是jar,需要编码),等待官方更新或降级HBase服务器。Rel

java - 使用 maven 构建的 spark 1.2 包 com.google.common 有错误

中央操作系统6.2Hadoop2.6.0scala2.10.5java版“1.7.0_75”OpenJDK运行时环境(rhel-2.5.4.0.el6_6-x86_64u75-b13)OpenJDK64位服务器VM(构建24.75-b04,混合模式)mvn版本ApacheMaven3.3.1(cab6659f9874fa96462afef40fcf6bc033d58c1c;2015-03-13T21:10:27+01:00)Maven主页:/opt/mavenJava版本:1.7.0_75,供应商:OracleCorporationJava主页:/usr/lib/jvm/java-1.

java - org.apache.solr.common.SolrException : Bad Request Bad Request request: http://localhost:8080/solr/update? wt=javabin&version=2

请大家帮帮我我正在尝试使用NUTCH抓取网站,但它给我错误“java.io.IOException:Jobfailed!”我正在运行此命令“bin/nutchsolrindexhttp://:8080/solr/crawl/crawldb-linkdbcrawl/linkdbcrawl/segments/*”并且我正在使用NUTCH1.5.1和SOLR3.6.1以及jdkjava-7-openjdk-i386和ubuntu12.04。在hadoop.log存在于NUTCH/log文件夹中显示以下内容:2012-09-1312:56:10,524INFOsolr.SolrIndexer-