r集成

bfrts1fy  于 2021-06-21  发布在  Storm
关注(0)|答案(1)|浏览(243)

我正在尝试将我的r脚本与storm集成。我的rbolt的代码是:

public class RBolt  extends ShellBolt implements IRichBolt {
public RBolt() {
    super("Rscript", "storm_OR.R");
}
@Override
public void declareOutputFields(OutputFieldsDeclarer outputFieldsDeclarer) {
    outputFieldsDeclarer.declare(new Fields("OR"));
}

@Override
public Map<String, Object> getComponentConfiguration() {
    Config ret = new Config();
    ret.setMaxTaskParallelism(1);
    return ret;
}
}

我得到以下错误。有什么帮助吗?我已经确定路径变量有r和rscript的路径。

17469 [Thread-12-__system] INFO  backtype.storm.daemon.executor - Preparing bolt __system:(-1)
17474 [Thread-12-__system] INFO  backtype.storm.daemon.executor - Prepared bolt __system:(-1)
17480 [Thread-6] INFO  backtype.storm.daemon.executor - Loading executor RBolt:[1 1]
17483 [Thread-6] INFO  backtype.storm.daemon.executor - Loaded executor tasks RBolt:[1 1]
17491 [Thread-6] INFO  backtype.storm.daemon.executor - Finished loading executor RBolt:[1 1]
17491 [Thread-6] INFO  backtype.storm.daemon.worker - Launching receive-thread for 8d8a13de-5e87-4e14-b2c2-59b4dfc070c6:1027
17493 [Thread-14-RBolt] INFO  backtype.storm.daemon.executor - Preparing bolt RBolt:(1)
17496 [Thread-15-worker-receiver-thread-0] INFO  backtype.storm.messaging.loader - Starting receive-thread: [stormId: EventProcessing-1-1457335172, port: 1027, thread-id: 0 ]
17500 [Thread-14-RBolt] INFO  backtype.storm.utils.ShellProcess - Storm multilang serializer: backtype.storm.multilang.JsonSerializer
17510 [Thread-14-RBolt] ERROR backtype.storm.util - Async loop died!
java.lang.RuntimeException: Error when launching multilang subprocess

    at backtype.storm.utils.ShellProcess.launch(ShellProcess.java:64) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
    at backtype.storm.task.ShellBolt.prepare(ShellBolt.java:99) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
    at backtype.storm.daemon.executor$fn__5641$fn__5653.invoke(executor.clj:690) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
    at backtype.storm.util$async_loop$fn__457.invoke(util.clj:429) ~[storm-core-0.9.2-incubating.jar:0.9.2-incubating]
    at clojure.lang.AFn.run(AFn.java:24) [clojure-1.5.1.jar:na]
    at java.lang.Thread.run(Thread.java:745) [na:1.7.0_67]
Caused by: java.io.IOException: Cannot run program "Rscript" (in directory "/tmp/933c85f3-f5b5-4a60-b342-7d4969b43d46/supervisor/stormdist/EventProcessing-1-1457335172/resources"): error=2, No such file or directory

tmp文件夹中的此目录不存在,是动态创建的。有什么建议吗。
更新:通过在项目的resources文件夹中创建另一个resources文件夹来解决这个问题,这样jar就有一个resources文件夹,其中包含r脚本。

hec6srdp

hec6srdp1#

“shell”组件的全部目的是作为一个独立的进程启动,因此您的脚本需要实现multilang协议。或者,您可以找到一个实现该协议并具有r集成的库,如fsstorm:它实现multilang,您可以通过r type provider调用r函数。

相关问题