草庐IT

execute_manager

全部标签

hadoop - 通过 Cloudera Manager 4.5 安装 Hadoop 后 HDFS 仅指向本地文件系统

安装ClouderaManager4.5后,我发现它没有配置为指向正确的默认文件系统。如果我从其中一个tasktracker/datanode框运行haddopfs-ls/,我只会得到本地文件系统。但是当我在cloudera中检查core-site.xml时,我看到了这个设置,这似乎是正确的:fs.defaultFShdfs://hadoop-namenode1:8020知道我应该在这里寻找什么吗?davidparks21@hadoop-reducedslot2:~$hadoopfs-ls/Found22itemsdrwxr-xr-x-rootroot40962013-04-1213:

java - (Hadoop) : reduce method is not getting executed/called while running mapreduce job

我在执行我的mapreduce作业时遇到问题。作为我的mapreduce任务的一部分,我正在使用mapreduce连接,其中包括多个map方法和单个reducer方法。我的两个map方法都被执行了,但是我的reducer没有被我的驱动程序类执行/调用。因此,最终输出只有在我的map阶段收集的数据。我是否在reduce阶段使用了错误的输入和输出值?map和reduce阶段是否存在输入输出不匹配?在这方面帮助我。这是我的代码..publicclassCompareInputTestextendsConfiguredimplementsTool{publicstaticclassFirstF

hadoop - Hadoop 中的 AccessControlException for access=EXECUTE

我有一个小应用程序,它从我的本地机器读取文件并将数据写入hdfs。现在我想列出hdfs文件夹中的文件,比如HadoopTest。当我尝试这样做时,出现以下异常:org.apache.hadoop.security.AccessControlException:Permissiondenied:user=rpoornima,access=EXECUTE,inode="/hbase/HadoopTest/Hadoop_File_1.txt":rpoornima:hbase:-rw-r--r--atorg.apache.hadoop.hdfs.server.namenode.FSPermis

hadoop - 从 org.apache.hadoop.hive.ql.exec.DDLTask 创建配置单元表 : FAILED: Execution Error, 返回代码 1 时出错。元异常

我有一个多节点hadoop集群,现在我在namenode上安装了hive。我试图从存储在hdfs中的文件创建一些配置单元表,但我收到了这个奇怪的错误:FAILED:ExecutionError,returncode1fromorg.apache.hadoop.hive.ql.exec.DDLTask.MetaException(message:hdfs://namenode-VirtualBox:9000/data/posts/posts.tblisnotadirectoryorunabletocreateone)hive>但是,然后我尝试从存储在hdfs中的文件创建一个表,只有2kb

hadoop - 如何从 Cloudera Manager REST API 获取事件名称节点主机名?

我能够访问Cloudera管理器restAPI。curl-uusername:passwordhttp://cmhost:port/api/v10/clusters/clusterName如何找到事件的namenode和resourcemangarer主机名?我无法从API文档中找到任何相关内容。http://cloudera.github.io/cm_api/apidocs/v10/index.html注意:集群配置高可用 最佳答案 您需要使用此端点:http://cloudera.github.io/cm_api/apidocs

hadoop - 失败 : Execution Error, 从 org.apache.hadoop.hive.ql.exec.DDLTask 返回代码 1。组织/apache/hadoop/hive/serde2/SerDe

我正在将Twitter数据处理到Hive外部表,但在创建Hive外部表时出现错误。请查看下面的我的代码。添加了jar文件以移动hive/lib位置。使用以下命令添加到jar文件配置单元我在配置单元库目录中添加了流动的jar:ADDJAR/usr/local/hive/lib/hive-serdes-1.0-SNAPSHOT.jar;请找到外部配置单元表:CREATEEXTERNALTABLEMytweets_raw(idBIGINT,created_atSTRING,sourceSTRING,favoritedBOOLEAN,retweet_countINT,retweeted_sta

java - 使用 Apache Sqoop 从 MySQL 导入数据 - 错误 : No manager for connect string

我正在尝试将Mahout与外部数据源集成。我正在关注ApacheMahoutCookbook为此预订。我已经配置了Hadoop2.4、MySQL服务器并且我已经将一个虚拟数据库导入到mysql中。我还按照书中的步骤安装了ApacheSqoop,并在Sqoop库(sqoop/lib)中下载并部署了mysql-connector-java-5.1.30.jar我用ant命令构建了sqoop:antmvn-install构建顺利。我正在尝试使用书中所述的以下命令从mysql导入数据:sqoopimport-all-tables--connectjdbc:mysql/localohost/bb

hadoop - Yarn Resource Manager UI 中的 Num Off Switch Containers 是什么意思?

我有一个ETL作业占用大量CPU和内存并运行了很长时间。我在调试时观察到的第一件事如下(来自资源管理器GUI上的作业)NumNodeLocalContainers(满足)=6NumRackLocalContainers(满足)=00NumOffSwitchContainers(满足)=11367我们只有两个架子。我需要帮助回答以下三个问题NumOffSwitchContainer的含义是什么?我如何识别这些“关闭开关”容器以及它们在哪些节点上运行?关闭开关容器是否会导致作业处理时间变慢? 最佳答案 1.NumOffSwitchCon

java.lang.NumberFormatException : For input string: "100" while executing MapReduce 异常

我正在编写一个MapReduce作业,用于在facebook上寻找共同的friend。这是我的映射器的输入:100,200300400500600200,100300400300,100200400500400,100200300500,100300600,100这是我的映射器代码的一部分:map{Stringline=value.toString();String[]LineSplits=line.split(",");String[]friends=LineSplits[1].trim().split("");for(inti=0;i当我执行此操作时,我在friend2中获得了正确

hadoop - 失败 : Execution Error, 从 org.apache.hadoop.hive.ql.exec.spark.SparkTask 返回代码 2

我在跑apache-hive-1.2.1-binhadoop-2.7.1spark-1.5.1-bin-hadoop2.6我能够在Spark上配置配置单元,但是当我尝试执行查询时,它会给我以下错误消息。hive>SELECTCOUNT(*)ASrcount,yomFromserviceGROUPBYyom;QueryID=hduser_20160110105649_4c90528a-76ba-4127-8849-54f2152be817Totaljobs=1LaunchingJob1outof1Inordertochangetheaverageloadforareducer(inbyt