草庐IT

Non-Local

全部标签

hadoop - 与 HDFS 通信 : Exception in thread "main" java. io.IOException : Failed on local exception: java. io.EOFException

publicstaticvoidmain(String[]args)throwsIOException{Configurationconf=newConfiguration();conf.addResource(newPath("/home/myname/hadoop-1.2.1/conf/core-site.xml"));conf.addResource(newPath("/home/myname/hadoop-1.2.1/conf/hdfs-site.xml"));System.out.println("AttemptinginitializationofFileSystem");

python - 从 s3 ://to local(hadoop) file system 复制文件时出错

我正在尝试使用python将文件从s3复制到hadoop文件系统。我收到以下错误:cp:`foo/ds=2015-02-13/ip-d1b-request-2015-02-13_10-00_10-09.txt.gz':Nosuchfileordirectory我最近正在迁移最新的hadoop版本(2.4.0)。在版本(0.20)中工作正常。为什么我在2.4.0版本中会出现此错误?在Hadoop版本0.20中hadoop@ip-10-76-38-167:~$/home/hadoop/bin/hadoopfs-cps3://test.com/foo/ds=2015-02-13/ip-d1b

hadoop - Hive INSERT OVERWRITE LOCAL DIRECTORY 不起作用

我正在使用Cloudera5.3.3Hive。我正在尝试执行以下查询,shell>pwd/homeshell>mkdirtest;chmod777test;shell>ls-aldrwxrwxrwx3jaijai4096Oct506:45testhivequery>INSERTOVERWRITELOCALDIRECTORY'/home/test/test1'SELECT*FROMsome_table;当我从hive客户端执行时,它工作正常,并在/home/test文件夹中创建输出文件,但如果我从执行相同的操作,它不会创建文件直线。从运行Hive服务器2的计算机通过beeline连接到H

hadoop - 使用 HDFS 而不是 spark.local.dir

试图理解为什么Spark需要本地机器上的空间!有办法解决吗?我一直遇到“设备上没有剩余空间”。我知道我可以将“spark.local.dir”设置为以逗号分隔的列表,但有没有办法改用HDFS?我正在尝试合并两个巨大的数据集。在较小的数据集上,Spark是MapReduce的对手,但在我用这些巨大的数据集证明之前,我不能宣布胜利。我没有使用yarn。此外,我们的网关节点(又名边缘节点)不会有很多可用空间。有解决办法吗? 最佳答案 当groupByKey操作时,Spark只是写入tmpDir序列化分区。它是普通文件(请参阅Shuffle

Hadoop:为什么我在 Namenode Information Web 中收到 "Max Non Heap Memory is -1 B."消息?这是什么意思?

我有一个使用VirtualBox制作的Hadoop2.6.5集群(一个主节点用作名称节点和数据节点,两个从节点)(easch节点安装了Xubuntu16.04)。先验,安装是正确的,因为我运行了一个wordcount示例并且没问题。在master:50070(我看到名称节点信息的地方),我得到这个:"MaxNonHeapMemoryis-1B."你知道这是什么意思吗?我找不到答案,我想检查一下,因为在运行wordcount之后我尝试运行我自己的程序但它没有成功,尽管它在我的Hadoop单节点安装中运行正常。我希望清楚,如果您需要更多信息,请告诉我。谢谢! 最

java - Cassandra 错误 :Invalid method name "describe local ring"

我正在使用java在hadoop中开发一个项目。当我在本地集群上运行我的代码(jar)时它工作正常但是当我在亚马逊多集群上运行它时它会给出异常...我的mapreduce作业代码....job.setJarByClass(ReadActivityDriver.class);job.setMapperClass(ReadActivityLogMapper.class);job.setReducerClass(ReadActivityLogReducer.class);job.setMapOutputKeyClass(Text.class);job.setMapOutputValueCla

hadoop - 在 hadoop 中释放 "Non-DFS used"空间

我正在尝试将我们的数据加载到hadoophdfs中。经过一些测试运行,当检查hadoopwebui时,我意识到标题“使用的非DFS”下占用了大量空间。事实上,“Non-DFSused”比“DFSused”要多。因此,几乎一半的集群被非DFS数据消耗。即使在重新格式化namenode并重新启动之后,这个“非DFS”空间也没有被释放。此外,我无法找到存储此“非DFS”数据的目录,因此我无法手动删除这些文件。我在网上阅读了很多陷入完全相同问题的人的帖子,但没有一个得到明确的答案。清空这个“非DFS”空间有那么难吗?还是我不应该删除它?我怎样才能释放这个空间? 最佳

linux -/usr/local 是不是必须要安装hadoop?

我正在尝试构建一个具有四个节点的hadoop集群。这四台机器来self学校的实验室,我发现它们的/usr/local是从同一个公共(public)磁盘挂载的,这意味着它们的/usr/local是相同的。问题是,我无法在从服务器上启动数据节点,因为hadoop文件总是相同的(比如tmp/dfs/data)。我计划在/opt等其他目录中配置和安装hadoop。问题是我发现几乎所有的安装教程都要求我们将它安装在/usr/local,所以我想知道如果我在其他地方安装hadoop会不会有什么不好的后果/选择?顺便说一句,我正在使用Ubuntu16.04 最佳答案

windows - 映射减少错误 : Failed to setup local dir

我在Windows8上安装的hadoop上运行mapreducewordcount示例。我收到如下错误。这听起来像是一个安全许可问题。但我不太确定。我在yarn-site.xml文件中添加了一个属性yarn.nodemanager.local-dirsc:\hadoop\tmp-nm任何想法都会很有帮助!15/07/1511:01:54INFOclient.RMProxy:ConnectingtoResourceManagerat/0.0.0.0:803215/07/1511:01:55WARNmapreduce.JobResourceUploader:Hadoopcommand-li

sql - Hive: java.lang.OutOfMemoryError: Java heap space and Job running in-process (local Hadoop)

我的设置:运行NixOSLinux的GoogleCloudPlatform中的4节点集群(1个主节点,3个工作节点)。我一直在使用TPC-DS工具包来生成数据和查询都是标准的。在较小的数据集/更简单的查询上,它们工作得很好。我从这里获取的查询:https://github.com/hortonworks/hive-testbench/tree/hdp3/sample-queries-tpcds这是第一个,query1.sql:WITHcustomer_total_returnAS(SELECTsr_customer_skASctr_customer_sk,sr_store_skASct