草庐IT

what_am_i

全部标签

hadoop - Spark 1.6.2 & yarn : diagnostics: Application failed 2 times due to AM Container for exited with exitCode: -1

我有一个由2台机器组成的集群,我正在尝试使用YARN集群管理器提交一个spark作业。基于hadoop2.6.2构建的vanillaSpark1.6.2普通Hadoop2.7.2我可以使用独立的集群管理器成功运行map-reduce作业和spark作业。但是当我用YARN运行它时,我得到了一个错误。对如何让它发挥作用有什么建议吗?如何启用更详细的日志记录?错误信息绝对不清楚为什么在hadoop/logs/userlogs/applicationXXX下没有创建日志文件?反问:IMO:hadoop日志记录和诊断不是很好。这是为什么?Hadoop似乎是一个成熟的产品。下面是输出:mike@

java - 使用 Thrift 运行 Hive Hook 时出现 YARN AM 容器错误

我正在构建一个工具,该工具需要我在HiveSemanticAnalyzer中运行MapReduce作业。当我运行处理启动Hive驱动程序的自定义Java程序时,MapReduce作业运行良好。但是,当我尝试通过修改HiveServer2和HiveJDBC(它可以很好地连接到我修改后的服务器)来执行Hook时,MapReduce作业失败并出现以下错误:Applicationapplication_1395851979242_0009failed2timesduetoAMContainerforappattempt_1395851979242_0009_000002exitedwithex

sql - HIVE ERROR : I am getting EOF error at 1, 对于第一个 LEFT OUTER JOIN 的 ON 子句之后的 WHERE 子句,对于配置单元中的以下代码

select*fromtable1aLEFTOUTERJOIN(select*fromtable99wherecol=1)bON(a.col1=b.col1)WHEREa.col2=b.col2ANDSIGN(a.col3)=1LEFTOUTERJOIN(select*fromtable99wherecol=2)cON(a.col1=c.col1)WHEREa.col2=c.col2ANDSIGN(a.col3)=1; 最佳答案 正确形成的SQL查询只有一个where子句(不包括CTE和子查询)。所以:select*fromtabl

hadoop - pig : What is the correct syntax to flatten a nested bag (2-levels deep)

我正在加载此数据:data6='item1'111{('thing1',222,{('value1'),('value2')})}使用这个命令A=load'data6'as(item:chararray,d:int,things:bag{(thing:chararray,d1:int,values:bag{(v:chararray)})});我正在尝试通过此命令将整个内容展平。A_flattened=FOREACHAGENERATEitem,d,things::thingASthing;things::d1ASd1,FLATTEN(things::values)ASvalue;但我只是

hadoop - 这不正常吧?所需的 AM 内存 (471859200+47185920 MB) 高于最大阈值 (2048 MB)

我已经阅读了很多有关通过设置yarn.scheduler.maximum-allocation-mb来解决此类问题的内容,我已将其设置为2gb,因为我当前正在运行selectcount(*)from我想这不是一个繁重的计算。但是什么是RequiredAMmemory(471859200+47185920MB)应该是什么意思其他问题说关于(1024+2048)问题或类似的东西。我在一台机器上设置,即我的桌面有4-gbram和2个内核。将Spark作为Hive执行引擎运行的规范是否非常低?目前我正在从java运行这项工作,我的设置是Connectionconnect=DriverManag

hadoop - 运行配置单元脚本 "am_stats_analyzer_163"cassandra 时出现 WSO2 BAM 错误

我在2个不同的虚拟机上运行APIM和BAM,在BAM上有一个外部Cassandra。我有一个“执行Hive脚本时出错。查询返回非零代码:9,原因:失败:执行错误,从org.apache.hadoop.hive.ql.exec返回代码2.MapRedTask"执行配置单元脚本时出错(am_stats_analyzer_163)这是完整的错误跟踪:TID:[0][BAM][2014-03-1812:34:07,948]ERROR{org.apache.hadoop.hive.ql.exec.ExecDriver}-EndedJob=job_local_0001witherrors{org.

Hadoop 2.7.5 - AM 容器启动错误

我已经看到多个与AMContainer启动错误相关的问题,但没有一个为我解决。我已经在我的MacOSXHighSierra笔记本电脑上安装了Hadoop2.7.5,并正在尝试Pi的示例mapreduce作业:hadoopjar/usr/local/hadoop/hadoop/share/hadoop/mapreduce/hadoop-mapreduce-examples-2.7.5.jarpi24所有服务都在运行:$jps69555NameNode69954NodeManager69750SecondaryNameNode70806JobHistoryServer69643DataNo

hadoop - Hive FunctionTask 执行错误,返回码-101 : What does it mean?

我正在运行使用cloudera管理器安装的clouderahadoop集群。我有一个UDF,我已使用直接配置单元CLI成功部署和运行它。这涉及使用“hive--auxpathxxx”向配置单元添加一些库jar,然后创建一个临时函数。但是当我尝试使用Hue+Beeswax做同样的事情时,我使用左侧方便的表单字段添加资源和临时函数,我不断收到此错误:FAILED:ExecutionError,returncode-101fromorg.apache.hadoop.hive.ql.exec.FunctionTask翻来覆去都找不到'-101'的错误码翻译的地方。我目前查看的日志不是很有用。是

基于matlab实现双路音频信号的AM调制与解调

文章目录一、代码解析二、滤波器的设置完整代码分享一、代码解析使用audioread读取音频信号,将采样率设置为100kHz,并利用awgn函数为信号添加高斯白噪声。%%读取信号添加高斯白噪声并播放fs1=1e5;%设定采样率为100kHz[x1,fs]=audioread('xiaomi1.wav');%输入第一路信号x1=resample(x1,fs1,fs);%对采样率进行调整fs=fs1;snr=20;%设置告诉白噪声与信号的信噪比px_dBW=0;%信号指定功率x1=awgn(x1,snr,px_dBW);%调用awgn函数为信号添加高斯白噪声[x2,fs]=audioread('xi

Hadoop Map-Reduce : what you can tell about a state: mappers: 80%, reducer :20%

在采访中有人问我一个问题:关于状态,你能说些什么:映射器:80%,缩减器:20%?我的理解是,进入那种状态是不可能的。因为在reducer开始工作之前,所有映射器都应该完成运行:收集所有键值对并按键分组。我说的对吗? 最佳答案 Reducers为20%意味着后台线程已开始将数据从mapper输出位置复制到reducer输入位置。这就是为什么在映射器输出达到100%之前,reducers进度显示为20%。 关于HadoopMap-Reduce:whatyoucantellaboutasta