我在一些数据节点上安装了r,可以编写map reduce作业,通过jri调用r。
接下来,为了通过配置单元查询调用r,我重写genericudafevaluator中的terminate方法,并在那里创建rengine对象。
那份老工作需要我去做 -Dmapred.child.env="R_HOME=/usr/lib64/R"
在它工作之前。
在配置单元中执行此操作时(通过set mapred.child.env=“r\u home=/usr/lib64/r”;)然后运行查询,作业在安装时失败。
一般来说,这是从hive获得的:
select count(*) from some_table limit 10;
但这失败了:
set mapred.child.env='abc=pqr';
select count(*) from some_table limit 10;
我有 hive-hwi-0.9.0-cdh4.1.1.jar
以及 hadoop-2.0.0-cdh4.1.1
1条答案
按热度按时间pbossiut1#
我删除了set语句中的引号,它成功了。你也应该这样做:
set mapred.child.env=abc=pqr;
select count(*) from some_table limit 10;
这很管用