草庐IT

TARGET_CLASS

全部标签

java - 方案 :hdfs and Class org. 没有找到 apache.hadoop.DistributedFileSystem 的文件系统

我想上传一个文件到HDFS。我使用以下jars作为依赖项编译了我的代码:hadoop-auth-2.6.1.jar,hadoop-common-2.6.1.jar和hadoop-hdfs-2.6.1.jar,我的代码:我用Ant编译的。但是,它给了我这个错误:NoFileSystemforscheme:hdfs。然后我改了代码,重新编译:但现在我遇到了另一个错误:Classorg.apache.hdfs.DistributedFileSystemnotfound。怎么了?我该怎么办? 最佳答案 DistributedFileSyst

Java hadoop 错误值类 : class RatioCount$WritableArray is not class org. apache.hadoop.io.DoubleWritable

我正在尝试学习hadoop。我有一个文本文件,其中每一行包含一个流量。信息以逗号分隔。我希望我的map函数输出一个字符串,我构建该字符串以标识一个流,如下所示:“123.124.32.614.23.64.2180tcp”作为键和一些double值(一个数字)。我希望我的reduce函数输出相同的字符串作为键和值,以从所有相似的键中获取所有值并将它们放入数组中。所以我想要这样的东西:“123.124.32.614.23.64.2180tcp”:[0.3-0.11-10.5]作为我的最终输出。当我运行它时出现错误:Error:java.io.IOException:wrongvaluecl

hadoop - 纱 : Could not find or load main class org. apache.hadoop.mapreduce.v2.app.MRAppMaster

尝试在Fedora上执行任何M/R2作业时出现此异常。Hadoop2.7.3和2.8.0有同样的问题。这包括Hive。[hadoop@masterhadoop]$yarnclasspath/opt/hadoop/hadoop-2.7.3/conf/opt/hadoop/hadoop-2.7.3/conf/opt/hadoop/hadoop-2.7.3/conf:/opt/hadoop/hadoop/share/hadoop/common/lib/*/opt/hadoop/hadoop/share/hadoop/common/*/opt/hadoop/hadoop/share/hadoo

Java 泛型和 Hadoop : how to get a class variable

我是一名.NET程序员,在Java中从事一些Hadoop工作,我有点不知所措。在Hadoop中,我正在尝试设置一个Map-Reduce作业,其中Map作业的输出键的类型为Tuple.当我使用setOutputKeyclass如下设置输出键时JobConfconf2=newJobConf(OutputCounter.class);conf2.setOutputKeyClass(Tuple.class);我遇到了一大堆错误,因为泛型和“.class”符号似乎不适用。尽管以下工作正常JobConfconf2=newJobConf(OutputCounter.class);conf2.setO

java - 错误 : Could not find or load main class org. apache.hadoop.hdfs.server.datanode.DataNode

我是apachehadoop的新手。我正在安装多节点集群,但出现两个错误。我不知道这些是什么类型的错误以及它们产生的原因。我在谷歌上搜索了很多关于这些错误的信息,但我无法找出错误产生背后的原因。Error:Couldnotfindorloadmainclassorg.apache.hadoop.util.PlatformNameError:Couldnotfindorloadmainclassorg.apache.hadoop.hdfs.server.datanode.DataNode这两个错误都是由于datanode或slaves引起的。我需要知道错误的种类、产生的原因以及如何解决它

java - Hadoop MapReduce : Strange Result when Storing Previous Value in Memory in a Reduce Class (Java)

如果我希望存储迭代器的当前值以与Reduce方法中迭代器的下一个值进行比较,Hadoop要求我克隆它而不是简单地将其引用分配给临时变量。我要将代码发布到我的reducer。你会看到两部分:Eclipse中测试的主要方法在Hadoop中执行的reduce方法你会注意到这两行代码是相同的,除了以下几点:main方法从我硬编码到其中的ArrayList获取Iterator,而reduce方法从mapper方法获取Iterator。main方法当然不会执行context.write。这是两者几乎共享的代码:MMIcurrentMMI=null;MMIpreviousMMI=null;Ultra

java - 为什么 ./sbin/start-master.sh 给出 "Error: Could not find or load main class org.apache.spark.launcher.Main"?

我是新手。我在单个节点上安装spark-1.5.2-bin-without-hadoop.tgz。我已完成配置。当我要使用以下命令启动我的主节点时,它向我显示错误。请帮助我。Command:./sbin/start-master.shstartingorg.apache.spark.deploy.master.Master,loggingto/usr/local/spark/sbin/../logs/spark-jalaj-org.apache.spark.deploy.master.Master-1-CIPL367.outfailedtolaunchorg.apache.spark.

java.lang.RuntimeException : Failed construction of Master: class org. apache.hadoop.hbase.master.HMaster

当我启动-hbase.shHMaster和HregionServer正在启动,但一段时间后不可见。通过查看日志,我发现了这一点。HMaster:java.lang.RuntimeException:FailedconstructionofMaster:classorg.apache.hadoop.hbase.master.HMasteratorg.apache.hadoop.hbase.master.HMaster.constructMaster(HMaster.java:3150)atorg.apache.hadoop.hbase.master.HMasterCommandLine.

hadoop - 错误 : Could not initialize class org. xerial.snappy.Snappy

我使用sqoop1.4.6将数据从RDBMS导入到hdfs,使用snappyCodec作为压缩和avro作为文件格式。我安装了以下组件Hadoop2.8.0Spark2.1.0hive1.2.2斯卡拉2.11.8Cassandra3.10当我尝试使用以下命令将mysql表导入hdfs时:sqoopimport--connectjdbc:mysql://******:****/retail_db--username****--password****--tableorder_items--compress--compression-codecorg.apache.hadoop.io.co

linux - 乌兹 : Sqoop dynamic target directory

我正在执行Oozie工作流中的sqoop作业。我可以在sqoop命令中创建具有静态名称的目标目录,如下所示。${jobTracker}${nameNode}job--execEMPLOYEE--meta-connectjdbc:hsqldb:hsql://:/sqoop----target-dir/user/test/Employee/20150126我需要创建带有日期的动态目标目录。我试过跟随,但没有用。${jobTracker}${nameNode}job--execEMPLOYEE--meta-connectjdbc:hsqldb:hsql://:/sqoop----target