从java执行hadoop示例jar文件

我正在Ubuntu 12.04和Eclipse 3.7上使用Hadoop 1.0.3，并且正在开发一个使用Windowbuider Pro执行Hadoop作业的GUI。我需要从GUI执行包含我的代码的jar文件。我已经使用runtime.getruntime.exec（）方法取得了一些成功。但是，虽然它执行特定于DFS的命令，但它不能执行.jar文件，例如捆绑在发行版中的PiEstimator。我的代码如下：从java执行hadoop示例jar文件

JButton btnYrhtrdsf = new JButton("Start Daemons"); 
btnYrhtrdsf.addMouseListener(new MouseAdapter() 
{ 
    @Override 
public void mouseClicked(MouseEvent e) 
    { 
    try { //WORKING 
    Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/start-dfs.sh"); 
    Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/start-mapred.sh"); 
    } 
     catch (IOException e1) { 
     e1.printStackTrace(); 
    } 
    } 
}); 
    contentPane.add(btnYrhtrdsf, "16, 10"); 

    JButton btnMakeDirectory = new JButton("Make Folder in HDFS"); 
    btnMakeDirectory.addMouseListener(new MouseAdapter() { 
     @Override 
     public void mouseClicked(MouseEvent e) {//WORKING 
      try { 
       Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/hadoop dfs -mkdir input2"); 
      } catch (IOException e1) { 
       // TODO Auto-generated catch block 
       e1.printStackTrace(); 
      } 
     } 
    }); 
    contentPane.add(btnMakeDirectory, "12, 18"); 

    JButton btnStopDaemons = new JButton("Stop Daemons"); 
    btnStopDaemons.addMouseListener(new MouseAdapter() { 
     @Override 
     public void mouseClicked(MouseEvent e) { 
      try { //WORKING 
       Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/stop-dfs.sh"); 
       Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/stop-mapred.sh"); 
      } catch (IOException e1) { 
       // TODO Auto-generated catch block 
       e1.printStackTrace(); 
      } 
     } 
    }); 
    contentPane.add(btnStopDaemons, "16, 18"); 

    JButton btnPiestimator = new JButton("PiEstimator"); 
    btnPiestimator.addMouseListener(new MouseAdapter() { 
     @Override 
     public void mouseClicked(MouseEvent e) { 
      try { //PROBLEM!!!!! 
       Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/hadoop jar hadoop-examples-1.0.3.jar pi 2 5"); 
      } catch (IOException e1) { 
       // TODO Auto-generated catch block 
       e1.printStackTrace(); 
      } 
     } 
    }); 
    contentPane.add(btnPiestimator, "14, 26"); 
}

来源

2013-03-03 Gaurav1991

替换下与线

Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/hadoop jar hadoop-examples-1.0.3.jar pi 2 5");

：

Runtime.getRuntime().exec("/usr/local/hadoop/hadoop-1.0.3/bin/hadoop jar /usr/local/hadoop/hadoop-1.0.3/hadoop-examples-1.0.3.jar pi 2 5");

来源

2013-03-03 15:14:13 ericson

从java执行hadoop示例jar文件

回答

相关问题