草庐IT

hadoop - 创建多层 HDFS 文件夹

要创建/user/SVLSTSLS/LostSales/sales-history-prepHDFS文件夹,可以像这样逐步创建HDFS文件夹:bash-4.1$hadoopfs-mkdir/user/SVLSTSLSbash-4.1$hadoopfs-mkdir/user/SVLSTSLS/LostSalesbash-4.1$hadoopfs-mkdir/user/SVLSTSLS/LostSales/sales-history-prep有什么方法可以创建最终文件夹sales-history-prep以及所有中间文件夹(SVLSTSLS和LostSales),如果还不存在?

python - 使用 .csv 格式的 HDFS 文件创建 Pandas DataFrame

我正在尝试通过从hadoop集群获取.csv数据并将其放入PandasDataFrame来创建Spark工作流。我能够从HDFS中提取数据并将其放入RDD中,但无法将其处理到PandasDataframe中。以下是我的代码:importpandasaspdimportnumpyasnmA=sc.textFile("hdfs://localhost:9000/sales_ord_univ.csv")#thiscreatestheRDDB=pd.DataFrame(A)#thisgivesmethefollowingerror:pandas.core.common.PandasError:

hadoop - 在 Spark 中,如何在没有 RDD 的情况下在 Hadoop 上写入文件?

SparkRDD具有saveAsTxtFile函数。但是,我如何打开一个文件并将一个简单的字符串写入hadoop存储?valsparkConf:SparkConf=newSparkConf().setAppName("example")valsc:SparkContext=newSparkContext(sparkConf)sc.hadoopConfiguration.set("fs.s3n.awsAccessKeyId","...")sc.hadoopConfiguration.set("fs.s3n.awsSecretAccessKey","...")vallines:RDD[St

hadoop - hadoop错误:util.NativeCodeLoader(hdfs dfs -ls不起作用!)

我已经看到很多人在安装hadoop时遇到问题。我经历了所有相关的stackoverflow问题,但无法解决问题。问题是:hdfsdfs-ls16/09/2709:43:42WARNutil.NativeCodeLoader:Unabletoloadnative-hadooplibraryforyourplatform...usingbuiltin-javaclasseswhereapplicablels:`.':Nosuchfileordirectory我正在使用ubuntu16.04,并且从Apache镜像下载了hadoop稳定版2.7.2:http://apache.spinell

file - Hadoop Map Reduce - 读取 HDFS 文件 - FileAlreadyExists 错误

我是Hadoop新手。我正在尝试使用以下代码读取HDFS上的现有文件。配置似乎文件和文件路径也是正确的。-publicstaticclassMapextendsMapper{privatestaticTextf1,f2,hdfsfilepath;privatestaticHashMap>friendsData=newHashMap();publicvoidsetup(Contextcontext)throwsIOException{Configurationconf=context.getConfiguration();Pathpath=newPath("hdfs://cshadoop

hadoop - 在hadoop中保存和访问类似表的数据结构

我想使用MapReduce编程在HDFS中保存和访问类似表的数据结构。此DS的部分内容如下图所示。这个DS有几万列和几百行,所有节点都应该可以访问它。我的问题是:如何将此DS保存在HDFS中并使用MapReduce编程访问它。我应该使用数组吗?(或Hive表?或Hbase?)谢谢。 最佳答案 HDFS是分布式文件系统,它将您的大文件存储在分布式服务器中。您可以使用命令将您的文件从本地系统复制到HDFShadoopfs-copyFromLocal/source/local/pathdestincation/hdfs/path复制完成后

hadoop - 在附件的 oozie 电子邮件操作中根据日期传递变量

我正在使用oozie发送带附件的电子邮件。我正在这样做。Actionfailed,errormessage[${wf:errorMessage(wf:lastErrorNode())}]xxxxxxxxxxxxxxx@xxxxxjobsuccesstext/plain/user/XXXX/logs/2017-05-03/exec.log现在在/user/XXXX/logs/2017-05-03/exec.log附近的工作流程中日期总是在变。我如何传递变量,以便在调用工作流时发送特定日期的附件。editedquestion.我的shell脚本:#!/bin/bashTIMESTAMP=`

hadoop - 无法访问 Namenode 网址

我尝试使用namenodeIP访问namenode的weburl。它抛出错误HTTPERROR404Problemaccessing/dfshealth.jsp。原因:NOT_FOUND我可以使用主机名访问Namenode网址。/etc/hosts文件:127.0.0.1localhost192.168.10.103impc2390192.168.10.102impc2359192.168.10.101impc2391192.168.10.111impc2394192.168.10.104impc2361我试过192.168.10.104:50070它抛出了一个错误,找不到页面我试过i

hadoop - 删除名称节点后从 HDFS 恢复文件

我的namenode服务器这个周末被黑了,/usr/local/hadoop目录不再存在。是否仍然可以恢复存储在HDFS上的文件?数据节点是可访问的,每个节点都包含层次结构blk_{...}数据中的某处。 最佳答案 如果您没有名称dir的任何副本/备份,恢复数据将是一项相当困难的任务。数据节点不知道文件的任何概念,只有block。所有数据都存在于这些block中,但您必须从它们的block中手动重建文件。如果您有一些非常重要的特定文件,但总体上没有那么多数据,您可以筛选block以找到您要查找的内容,但我不知道有什么比这更好的了。这

hadoop - 为什么在使用 hadoop fs -put 命令时 mapreduce 没有启动?

请原谅这个基本问题。但我想知道为什么当我们尝试加载一些大小大于block大小时的mapreduce作业没有启动。我在某个地方了解到MapReduce将负责将数据集从LFS加载到HDFS。那为什么当我给hadoopfs-put命令时我无法在控制台上看到mapreduce日志?提前致谢。 最佳答案 您正在考虑将生成MapReduce作业的hadoopdistcp。https://hadoop.apache.org/docs/stable/hadoop-distcp/DistCp.htmlDistCpVersion2(distribute