来自配置单元UDF / UDAF的JRI

Question

我在一些数据节点上安装了R，并且可以编写Map reduce作业来通过JRI调用R。

接下来，为了通过hive查询调用R，我覆盖了GenericUDAFEvaluator中的terminate方法，并在其中创建了Rengine对象。

旧的mapred作业需要我先做-Dmapred.child.env="R_HOME=/usr/lib64/R"，然后才能工作。

当我在hive中执行此操作(通过设置mapred.child.env="R_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

Answer 1

我删除了set语句中的引号，它起作用了。也是如此：

set mapred.child.env=abc=pqr;

select count(*) from some_table limit 10;

这是可行的