0

我是 R 编程的新手。

我在设置所有环境变量后使用下面的代码。所有连接都运行良好,但在to.dfs下面执行时出现错误。

请指导我。

Sys.setenv("HADOOP_CMD"="/usr/local/hadoop/bin/hadoop")
Sys.setenv("HADOOP_CONF"="/usr/local/hadoop/conf")
Sys.setenv("HADOOP_STREAMING"="/usr/local/hadoop/share/hadoop/tool/lib/hadoop-streaming-2.6.0.jar")

library(rhdfs)
hdfs.init()
library(rmr2)
library(plyrmr)
hdfs.ls('/user/hduser/')

sample <- 1:500

small.ints <- to.dfs(sample)

我收到错误消息:

不是有效的 JAR:/usr/local/hadoop/share sh:2:hadoop/tools/lib/hadoop-streaming-2.6.0.jar:未找到

4

0 回答 0