草庐IT

dynamic-update

全部标签

hadoop - 配置单元设置 hive.optimize.sort.dynamic.partition

我正在尝试插入具有动态分区的配置单元表。同一查询在过去几天一直运行良好,但现在出现以下错误。DiagnosticMessagesforthisTask:java.lang.RuntimeException:org.apache.hadoop.hive.ql.metadata.HiveException:HiveRuntimeError:Unabletodeserializereduceinputkeyfromx1x128x0x0x46x234x240x192x148x1x68x69x86x50x0x1x128x0x104x118x1x128x0x0x46x234x240x192x148

ubuntu - update-alternatives 在 CDH4 安装中抛出错误

我正在我的ubuntu12.04系统上安装CDH4。当我使用update-alternative指向我的hadoop_conf时,它会抛出一个错误。我到处搜索,但没有找到解决这个问题的办法。使用的命令:-sudoupdate-alternatives--install/etc/hadoop/confhadoop-conf/etc/hadoop/conf.my_cluster50sudoupdate-alternatives--sethadoop-conf/etc/hadoop/conf.my_cluster这给出了一个错误...update-alternatives:error:can

hadoop - 级联 sinkmode.update 不工作

我刚开始级联编程并且有一个级联作业需要运行可变的迭代次数。在每次迭代期间,它从前一次迭代生成的文件(Tap)准备好并将计算的数据写入两个单独的SinkTaps。OneTap(TapFinal)用于收集每次迭代的数据。另一个Tap(Tapintermediate)用来收集下一次迭代需要计算的数据。我正在使用SinkMode.UPDATE来实现“Tapfinal”。它在本地模式下工作正常。但在集群模式下失败。提示文件已经存在(“Tapfinal”)。我正在运行CDH4.4和级联2.5.2。似乎没有人遇到过同样的问题。如果有人知道任何可能的修复方法,请告诉我。谢谢Causedby:org.a

Hadoop Distcp - 增加 distcp.dynamic.max.chunks.tolerable 配置和调整 distcp

我正在尝试使用distcp在两个hadoop集群之间移动数据。大量的小文件需要移动大量的数据。为了让它更快,我尝试使用-strategydynamic,根据文档,它“允许更快的数据节点比更慢的节点复制更多的字节”。我将映射器的数量设置为400。当我启Action业时,我看到此错误:java.io.IOException:使用splitRatio:2、numMaps:400创建的block太多。减少numMaps或降低拆分比率以继续。当我用谷歌搜索时,我找到了这个链接:https://issues.apache.org/jira/browse/MAPREDUCE-5402在这个链接中,作

apache-spark - Spark : Understanding Dynamic Allocation

我已经启动了一个具有以下配置的spark作业:--masteryarn--deploy-modecluster--confspark.scheduler.mode=FAIR--confspark.dynamicAllocation.enabled=true--confspark.dynamicAllocation.maxExecutors=19--confspark.dynamicAllocation.minExecutors=0它运行良好并成功完成,但在检查sparkhistoryui后,这是我看到的:我的问题是(我关心的是理解而不是解决方案):如果没有任务可做,为什么spark会请

Hadoop eclipse 插件 2.6 - 在 : "Map/Reduce location status updater". java.lang.NullPointerException 期间发生内部错误

在EclipseHadoopplugin2.6中添加新的Hadoop位置,并尝试扩展位置时出现此错误Aninternalerroroccurredduring:"Map/Reducelocationstatusupdater".java.lang.NullPointerException请看下面的图片:http://i.imgur.com/029g7Vq.jpg.http://i.imgur.com/RIlEPH6.jpg.顺便说一句,我需要为“Map/Reduce(V2)MasterSection”配置hadoop中的哪一部分配置?对我来说,端口54333没有在Master服务器上监

hadoop - 使用 hive.optimize.sort.dynamic.partition 选项避免单个文件

我正在使用配置单元。当我使用INSERT查询编写动态分区并打开hive.optimize.sort.dynamic.partition选项(SEThive.optimize.sort.dynamic.partition=true)时,总是有单个每个分区中的文件。但是如果我关闭该选项(SEThive.optimize.sort.dynamic.partition=false),我会遇到这样的内存不足异常。TaskAttempt3failed,info=[Error:Errorwhilerunningtask(failure):attempt_1534502930145_6994_1_01

linux - 乌兹 : Sqoop dynamic target directory

我正在执行Oozie工作流中的sqoop作业。我可以在sqoop命令中创建具有静态名称的目标目录,如下所示。${jobTracker}${nameNode}job--execEMPLOYEE--meta-connectjdbc:hsqldb:hsql://:/sqoop----target-dir/user/test/Employee/20150126我需要创建带有日期的动态目标目录。我试过跟随,但没有用。${jobTracker}${nameNode}job--execEMPLOYEE--meta-connectjdbc:hsqldb:hsql://:/sqoop----target

java - org.apache.solr.common.SolrException : Bad Request Bad Request request: http://localhost:8080/solr/update? wt=javabin&version=2

请大家帮帮我我正在尝试使用NUTCH抓取网站,但它给我错误“java.io.IOException:Jobfailed!”我正在运行此命令“bin/nutchsolrindexhttp://:8080/solr/crawl/crawldb-linkdbcrawl/linkdbcrawl/segments/*”并且我正在使用NUTCH1.5.1和SOLR3.6.1以及jdkjava-7-openjdk-i386和ubuntu12.04。在hadoop.log存在于NUTCH/log文件夹中显示以下内容:2012-09-1312:56:10,524INFOsolr.SolrIndexer-

hadoop - 配置单元加载数据 :how to specify file column separator and dynamic partition columns?

好吧,我有一些关于将mysql数据加载到hive2的问题,并且不知道如何指定分隔符,我尝试了serval次但一无所获。下面是hive表,id是分区列,0:jdbc:hive2://localhost/>desctest;+-----------+------------+----------+|col_name|data_type|comment|+-----------+------------+----------+|a|string|||id|int||+-----------+------------+----------+当我执行loaddatalocalinpath'fil