使用runtime.exec从java运行hadoop jar命令

bq8i3lrv 于 2021-05-29 发布在 Hadoop

关注(0)|答案(2)|浏览(410)

我正在尝试使用runtime.exec从java运行hadoopjar命令。下面是示例代码：

Runtime.getRuntime().exec(new String[]{"bin/hadoop", "jar /home/hadoop/jar/test.jar /user/hduser/myinput/input /user/hduser/newoutput"});

然而，我没有得到想要的输出。下面是我想从java执行的hadoop命令：

bin/hadoop jar /home/hadoop/jar/test.jar /user/hduser/myinput/input /user/hduser/newoutput

我也没有任何例外。runtime.getruntime（）.exec的使用方式是否错误？

2条答案

将命令替换为以下命令：

Runtime.getRuntime().exec("HADOOP_HOME/bin/hadoop jar /home/hadoop/jar/test.jar /user/hduser/myinput/input /user/hduser/newoutput");

给出定义驱动程序代码的类名。

bin/hadoop jar /home/hadoop/jar/test.jar Package_name.className /user/hduser/myinput/input /user/hduser/newoutput