草庐IT

Task_disconnected_while_still_run

全部标签

java.lang.NoSuchFieldError : INSTANCE in HttpClient when running Oozie 错误

我有一个Java应用程序(作为Maven项目),它使用HttpClient(v4.5)访问RESTAPI,然后将GET响应作为JSON写入HDFS。这在EclipseIDE中工作正常。这是我的依赖项:org.apache.httpcomponentshttpclient4.5com.google.code.gsongson2.3.1org.apache.hadoophadoop-client2.2.0当我尝试将它与Oozie集成时,因为我计划定期进行RESTAPI调用和HDFS写入,我遇到了:Causedby:java.lang.NoSuchFieldError:INSTANCEato

hadoop - 作业从 RUNNING 跳转到 PREP 状态

当我运行mapreduce作业时,它从RUNNING跳转至PREP状态。我查看了mapreduce日志,但没有发现任何异常。我想知道这是否与yarn配置有关。所以,我查看了mapred-site.xml的配置[2],似乎内存大小是正确的。尽管我已将mapreduce设置为以32GB(yarn.nodemanager.resource.memory-mb32218)运行,但我在具有16个内核和64GBRAM的PC上运行。有什么尝试调试这个的建议吗?[1]工作状态Totaljobs:1JobIdStateStartTimeUserNameQueuePriorityUsedContainer

scala - Apache Spark : how to cancel job in code and kill running tasks?

我在客户端模式下使用Yarn(版本2.6.0)在Hadoop集群上运行Spark应用程序(版本1.6.0)。我有一段运行长时间计算的代码,如果它花费的时间太长,我想终止它(然后运行一些其他函数)。这是一个例子:valconf=newSparkConf().setAppName("TIMEOUT_TEST")valsc=newSparkContext(conf)vallst=List(1,2,3)//settingupaninfiteactionvalfuture=sc.parallelize(lst).map(while(true)_).collectAsync()try{Await.

mysql - sqoop 作业将数据导出到 mysql,卡在 map 100% with status running

所以我尝试使用sqoop将数据从impala导出到mysql,这是由oozie作业安排的。但是当第一个sqoop操作开始时,它停留在map100%和reduce0%,并且所有其他操作都被填充。奇怪的是,在我kill这个oozie作业之前,mysql中没有数据,但是在我kill之后,mysql表中出现了数据(只有与第一个卡住的sqoopAction相关的表)。这是我的导出脚本:enterimagedescriptionhere我的oozie工作操作如下所示:thefirstrunningistheonestuck并且没有错误日志存在。 最佳答案

hadoop - 在配置单元 "Unable to retrieve URL for Hadoop Task logs. Does not contain a valid host:port authority: local"上出现错误

在涉及mapreduce的hive上执行任何查询时,我收到此错误。“UnabletoretrieveURLforHadoopTasklogs.Doesnotcontainavalidhost:portauthority:local” 最佳答案 报告的异常出现在旧版本的Hadoop中(即YARN之前)。大多数情况下,您使用的是旧版本的Hadoop。当mapred.job.tracker的值出现异常参数在local中设置为“mapred-site.xml”相反,它应该是:. 关于hadoop

hadoop - Hbase设置配置: HMaster is not running

我正在尝试以完全分布式模式设置HBase:由1个主服务器和2个区域服务器组成。我在hbase-env.sh中设置了HBASE_MANAGES_ZK=true。hadoop集群在集群上运行,配置如下:主人:节点主人Regionserver1:node1Regionserver2:node2当我启动HBase时,我可以看到RegionServers正在启动,主服务器上的HQuorumPeer也在启动,但HMaster没有显示。请找到如下日志:掌握hbase-site.xmlhbase.masternodemaster.hbasecluster.com:60000Thehostandport

hadoop - 能否在 Hadoop 集群中的 Map Task 中启动特定进程?

我使用具有一个节点的Hadoop和YARN集群。所有hadoop和yarn守护进程都在这个节点中启动。我还使用ApacheNutch1.15分布式爬网启动了一个获取步骤,成功完成了注入(inject)和生成步骤。我正在尝试使用Selenium3.149.54FirefoxDriver在YarnChild容器上运行的maptask中运行Firefox浏览器。Firefox进程启动,但弹出一个窗口,提示Firefox配置文件丢失或无法访问,maptask被阻止,直到我关闭该窗口。Selenium3.141.54FirefoxDriver使用geckodriver启动Firefox,从容器用

vector - java.lang.OutOfMemoryError : Java heap space error while running seq2sparse in mahout 错误

我正在尝试在mahout中使用k-means对一些手工制作的日期进行聚类。我创建了6个文件,每个文件中几乎没有1或2个单词的文本。使用./mahoutseqdirectory从它们中创建一个序列文件。在尝试使用./mahoutseq2sparse命令将序列文件转换为向量时,出现java.lang.OutOfMemoryError:Javaheapspace错误。序列文件大小为0.215KB。命令:./mahoutseq2sparse-imokha/output-omokha/vector-ow错误日志:SLF4J:ClasspathcontainsmultipleSLF4Jbindin

Hadoop reducer : How to ensure the reducers are evenly running over a number of nodes

我有一个场景,我不确定减少处理器的位置。i)我有一个输入文本文件,它有1到4之间平衡范围内的1000个整数。ii)让我们假设有一个4节点集群,每个节点有12个槽,其中4个分配为reducer-总共有16个reduce槽iii)我在驱动程序中设置了reducer的数量:jobConf.setNumReduceTasks(4);iii)最后我有一个分区方法是publicclassMyPartitionerextendsPartitioner{@OverridepublicintgetPartition(Textkey,Textvalue,intnumPartitions){returnIn

hadoop - 画面 : Error while using Impala to connect to Cloudera Hadoop

我正在研究如何使用Tableau连接到ClouderaHadoop。我提供服务器和端口详细信息并使用“Impala”进行连接。我能够成功连接,选择默认模式并选择所需的表。在此之后,当我将维度或度量拖放到“网格”上的行/列时,出现以下错误:[Cloudera][Hardy](22)来自ThriftHiveClient的错误:查询返回非零代码:10025,原因:失败:SemanticException[错误10025]:第1:7行表达式不在GROUPBY键中''.但是,如果我尝试使用与“HiveServer”(而不是“Impala”)相同的连接类型,它工作正常。我们不确定哪里出错了。非常感