@Override
            public void run() {
                try {
                    BufferedReader reader;
                    reader = new BufferedReader(new InputStreamReader(mpiExecProcess.getInputStream()));
                    String mpiExecOutput;
                    while ((mpiExecOutput = reader.readLine()) != null) {
                        LOG.info(mpiExecOutput);
                        appendMessage(new Message(LogType.STDOUT, mpiExecOutput));
                        extractMpiRTECommand(mpiExecOutput, amContainerStdOut);
                    }
                } catch (Exception e) {
                    LOG.warn("Error in mpi exec process stdinThread");
                }
            }
Application Master launch "mpiexec" process locally for mpi app
core/src/main/java/net/qihoo/hbox/AM/ApplicationMaster.java