我对r编程是新手。
设置完所有env变量后,我使用下面的代码。所有连接都工作正常,但我在执行下面的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:未找到
暂无答案!
目前还没有任何答案,快来回答吧!