草庐IT

hdfs-agent

全部标签

hadoop - hdfs fsck 权限被拒绝

我正在运行此命令行来解决损坏的HDFS文件的问题:hdfsfsck/我收到这个警告:Connectingtonamenodeviahttp://master1:50070FSCKstartedbyroot(auth:SIMPLE)from/192.168.1.30forpath/atMonOct2405:06:23EDT2016FSCKendedatMonOct2405:06:23EDT2016in1millisecondsPermissiondenied:user=root,access=READ_EXECUTE,inode="/accumulo":accumulo:accumulo

hadoop - 上传文件到hadoop hdfs?

大家好,我是hadoop的新手,这是我的大学作业,所以我正在做一些研究,我已经安装了hadoop-2.7.3,但我找不到路径,我应该在哪里上传文件以通过hadoop本地主机检查它?这张图是为datanodes和namenodes制作的文件夹在hadoop_store里面在hdfs文件夹内谁能告诉我应该在此处提供什么链接。任何帮助将不胜感激寻求帮助 最佳答案 不能直接复制文件,应该使用命令行上传文件到hdfs。此命令会将1.txt放入hdfs的根目录。hadoopfs-put/home/hduser/1.txt/

hadoop - Systemd Hdfs 服务 [hadoop] - 启动

我已经创建了一个服务来启动和停止与我的spark集群关联的我的hdfs。服务:[Unit]Description=Hdfsservice[Service]Type=simpleWorkingDirectory=/home/hduserExecStart=/opt/hadoop-2.6.4/sbin/start-service-hdfs.shExecStop=/opt/hadoop-2.6.4/sbin/stop-service-hdfs.sh[Install]WantedBy=multi-user.target问题是当我启动服务时,它会在启动后立即启动和停止!!:)我认为问题是服务的类

hadoop - 使用 Nifi 将数据提取到 HDFS - 无法访问文件

所以,我是第一次使用NiFi。我正在尝试使用它来调用API,然后将数据通过管道传输到HDFS(HortonworksSandbox2.4)。我目前只使用2个处理器:GetHTTP和PutHDFS。我似乎两个处理器都配置正常...它们运行,但我无法找到当我通过Ambari进入Hadoop时创建的输出文件...我已将输出目录设置为/user/,但什么也没有出现。但是,我在PutHDFS处理器上收到一条警告消息,建议:WARNINGPutHDFS[...]penalizingStandardFlowFileRecord[...]androutingtofailurebecausefilewi

java - hadoop mapreduce : where's the final hdfs result file when I speficify multiple reducers?

我有一个wordCount.java程序并修改它以支持多个映射器和缩减器,如下所示:publicclassWordCountextendsConfiguredimplementsTool{publicintrun(String[]args)throwsException{JobConfconf=newJobConf(getConf(),w1_args.class);for(inti=0;i然后我编译并运行它:hadoopjarWordCount-1.0-SNAPSHOT.jarWordCount-m3-r15inputoutput它运行良好,当我检查输出目录时:$hdfsdfs-lso

hadoop - 如何跟踪 NiFi 中的 HDFS Active Namenode 更改事件?

我有HDFS集群,其中包含Active和StanbyNamenodes。有时,当集群重新启动时,Namenode会交换它们的角色-Standby变为Active,反之亦然。然后我让NiFi流和PutParquet处理器将一些文件写入这个HDFS集群。处理器的目录属性配置为“hdfs://${namenode}/some/path”,其中${namenode}变量值类似于“first.namenode.host.com:8020”。现在,当集群重新启动并且实际的Namenode更改为“second.namenode.host.com:8020”时,NiFi中的配置没有更新,处理器仍然尝试

hadoop - 使用 Nifi 将文件从 SFTP 服务器复制到 HDFS

我正在尝试从SFTP服务器加载包含225GB(文件数量约为1,75,000)的庞大数据,并将数据复制到HDFS。为了实现上述场景,我们使用了2个处理器。GetSFTP(从SFTP服务器获取文件)已配置处理器->递归搜索=true;使用自然排序=true;远程轮询批量大小=5000;并发任务=32.PutHDFS(将数据推送到HDFS)已配置的处理器->并发任务=3;冲突解决策略=replace;Hadoop配置资源;目录但是一段时间后,数据复制停止并且它的大小在HDFS中没有更新。当我在GetSFTP中将RemotePollBatchSize配置设置为5000->推送到HDFS的总数据

apache-spark - 如何将托管在 HDFS 中的配置文件传递给 Spark 应用程序?

我正在使用SparkStructuredStreaming。另外,我正在使用Scala。我想将配置文件传递给我的spark应用程序。此配置文件托管在HDFS中。例如;spark_job.conf(HOCON)spark{appName:"",master:"",shuffle.size:4etc..}kafkaSource{servers:"",topic:"",etc..}redisSink{host:"",port:999,timeout:2000,checkpointLocation:"hdfslocation",etc..}如何将它传递给Spark应用程序?我如何在Spark中

docker - Hue 访问 HDFS : bypass default hue. ini?

设置我正在尝试使用bde2020提供的图像组成一个轻量级的最小hadoop堆栈。(学习目的)。现在,堆栈包括(除其他外)一个名称节点数据说明色调基本上,我是从欧洲大数据开始的officialdockercompose,并添加了一个基于theirdocumentation的色调图像问题Hue的文件浏览器无法访问HDFS:Cannotaccess:/user/dav.TheHDFSRESTserviceisnotavailable.Note:youareaHueadminbutnotaHDFSsuperuser,"hdfs"orpartofHDFSsupergroup,"supergrou

hadoop - 无法将现有文件附加到 HDFS

我在VM上运行单节点Hadoop1.2.1集群。我的hdfs-site.xml如下所示:dfs.replication1Defaultblockreplication.dfs.support.appendtrueDoesHDFSallowappendstofiles?现在,当我尝试从Eclipse运行以下代码时,它始终返回false:Configurationconfig=newConfiguration();config.set("mapred.job.tracker","10.0.0.6:54311");config.set("fs.default.name","hdfs://10