草庐IT

HADOOP_PREFIX

全部标签

hadoop - 当 Hadoop 集群宕机时,数据是否保留在 HDFS 中?

我是Qubole的新手,想知道Hadoop集群宕机后数据是否仍在HDFS中?感谢任何帮助。谢谢。 最佳答案 HDFS上的数据没有丢失。我们不备份/恢复HDFS。EC2/S3上的计算模型是长期存在的数据始终存在于S3上,而HDFS仅用于中间数据和控制数据。我们有时也使用HDFS(和本地磁盘)作为缓存。 关于hadoop-当Hadoop集群宕机时,数据是否保留在HDFS中?,我们在StackOverflow上找到一个类似的问题: https://stackover

hadoop - HBase mapReduce TableOutputFormat如何使用Flush和WAL

因此,当从使用TableOutputFormat的MapReduce作业写入HBase时,它​​多久写入一次HBase。我不认为它会为每一行执行一个put命令。在MapReduce中使用时如何控制AutoFlush和WriteAheadLog(WAL)? 最佳答案 TableOutputFormat禁用AutoFlush并使用在hbase.client.write.buffer指定的写入缓冲区(默认为2MB),一旦缓冲区已满,它会自动刷新到HBase。您可以通过将属性添加到作业配置来更改它:config.set("hbase.cli

hadoop - 无法将数据加载到配置单元中的分区表中

我无法将数据加载到分区表中,因为它显示“动态分区严格模式需要至少一个静态分区列。要关闭此功能,请设置hive.exec.dynamic.partition.mode=nonstrict“即使在设置sethive.exec.dynamite.partition.mode=nonstrict时也会出现上述错误;配置单元>设置hive.exec.dynamite.partition=true;这些参数我得到了同样的错误。请建议我更好的解决方案。提前致谢; 最佳答案 你有各种各样的错别字(还有一种很有趣的把事情搞砸的倾向):hive.exe

hadoop - 作业跟踪器和名称节点不以 start-all.sh 开头

我正在尝试安装hadoop单节点,但它无法正常工作。当我执行start-all.shnamenode和jobtracker时,不要启动。您是否在我的文件中看到什么可能是错误的,所以我得到了这个结果?hadoopjps命令的结果:14878日元14823任务追踪器14605二级名称节点14456数据节点start-all.sh命令的结果:admin@vm-sgd10:/usr/local$start-all.shstartingnamenode,loggingto/usr/local/hadoop/libexec/../logs/hadoop-admin-namenode-vm-10.v

hadoop - Cloudera Manager CDH Parcel 分发错误

我正在尝试使用CentOS6机器在Rackspace云上安装Hadoop集群。从cloudera管理器创建新集群时出现以下错误。有人可以帮忙吗。集群安装安装选定的包裹正在将选定的包裹下载并安装到集群中的所有主机上。CDH5.3.2-1.cdh5.3.2.p0.103个错误Errorwhendistributingtovm-cdh-cluster-3:[Errnosocketerror][Errno-2]Nameorservicenotknown.Errorwhendistributingtovm-cdh-cluster-1:[Errnosocketerror][Errno-2]Name

hadoop - 如何将事件拆分为多个事件以将它们发送到多路复用扇出流

我们计划使用kafkaflume-ng集成(Flafka),其中flume是kafka队列的消费者。Flume代理将接收文件列表命令及其输出,如下所示:root@host>[Command1][Output1]root@host>[Command2][Output2]该文件可能包含多个命令,并且一个命令的输出可能很大。我们需要拦截事件(也就是文件数据),根据命令将事件拆分成多个事件。然后源会将流扇出到多个channel,将每个子事件发送到一个channel(使用多路复用),每个接收器将命令信息存储到各自的Hive表。是否可以使用扇出流将一个事件拆分为多个事件?或者换句话说,我们可以在拦

hadoop - 在 spark yarn 集群中,容器如何工作取决于 RDD 分区的数量?

我有一个关于ApacheSpark(yarn集群)的问题虽然在这段代码中,创建了10个分区但是在yarncluster中,只需要3个contatinervalsc=newSparkContext(newSparkConf().setAppName("SparkCount"))valsparktest=sc.textFile("/spark_test/58GB.dat",10)valtest=sparktest.flatMap(line=>line.split("")).map(word=>(word,1))在sparkyarn集群中,容器如何工作取决于RDD分区的数量?*因为我只有一点

maven - 如何配置 GIRAPH 1.1.0 pom.xml 使其与 HADOOP 2.6.0 一起工作?安装错误

我正在尝试将GIRAPH1.1.0添加到HADOOP2.6.0我必须以某种方式编辑pom.xml才能正确打包GIRAPH。我运行命令mvn-Phadoop_yarn-Dhadoop.version=2.6.0package我在行(1292)中编辑了默认的pom.xml文件:hadoop_2giraph-accumulogiraph-hbasegiraph-hcataloggiraph-hivegiraph-goragiraph-rexstergiraph-dist2.6.0但是当我运行它给出的命令时[INFO]ApacheGiraphParent....................

hadoop - HBase 未连接到 ZooKeeper

我正在努力让我的HBaseshell运行。它在主题行中抛出上述异常。我检查过hbase-site.xml与hadoop完美匹配。请帮忙。我挣扎了2天,有一个项目到期。我附上hadoop和hbase的两个xml文件。hbase-site.xmlhbase.rootdirhdfs://localhost:54310/hbasehbase.zookeeper.property.dataDir/home/hduser/zookeeperhbase.zookeeper.property.clientPort2222PropertyfromZooKeeper'sconfigzoo.cfg.Thep

java - import org.apache.hadoop 无法解析

我已经看到这个问题,但似乎没有任何修复对我有用。或者更有可能是我做错了,因为我对此很陌生。(在eclipse中工作)我收到以下行的错误Theimportorg.apache.hadoopcannotberesolved:importorg.apache.hadoop.conf.Configuration;importorg.apache.hadoop.filecache.DistributedCache;importorg.apache.hadoop.fs.FileSystem;importorg.apache.hadoop.fs.Path;importorg.apache.hadoo