Difference between revisions of "Tutorial: Running MPI Programs on Hadoop Cluster"

From dftwiki3
Jump to: navigation, search
(→‎Setup Aliases)
(→‎Setup Password-Less ssh to the Hadoop cluster)
 
(16 intermediate revisions by the same user not shown)
Line 5: Line 5:
 
__TOC__
 
__TOC__
 
<br />
 
<br />
 +
=Change your Password=
 +
<br />
 +
* Login to hadoop01 with the accounts provided to you, and change your temporary password:
 +
 +
  passwd
 +
 +
* You should now be all set.
 +
<br />
 +
 
=Setup Password-Less '''ssh''' to the Hadoop cluster=
 
=Setup Password-Less '''ssh''' to the Hadoop cluster=
 +
<br />
 +
[[Image:MPIHapoopClusterStep1.png|600px|center]]
 
<br />
 
<br />
 
<onlysmith>
 
<onlysmith>
Line 23: Line 34:
 
  ls .ssh
 
  ls .ssh
 
  cd .ssh
 
  cd .ssh
−
mv id_rsa id_rsa.mpi
 
−
mv id_rsa.pub id_rsa.mpi.pub
 
 
  ssh yourusername@hadoop02.dyndns.org mkdir -p .ssh
 
  ssh yourusername@hadoop02.dyndns.org mkdir -p .ssh
−
  cat ~/.ssh/id_rsa.mpi.pub | ssh yourusername@hadoop02.dyndns.org 'cat >> .ssh/authorized_keys'
+
  cat ~/.ssh/id_rsa.pub | ssh yourusername@hadoop02.dyndns.org 'cat >> .ssh/authorized_keys'
 
</source>
 
</source>
 
<br />
 
<br />
Line 37: Line 46:
 
:::<source lang="text">
 
:::<source lang="text">
 
  ssh yourusername@hadoop03.dyndns.org mkdir -p .ssh
 
  ssh yourusername@hadoop03.dyndns.org mkdir -p .ssh
−
  cat ~/.ssh/id_rsa.mpi.pub | ssh yourusername@hadoop03.dyndns.org 'cat >> .ssh/authorized_keys'
+
  cat ~/.ssh/id_rsa.pub | ssh yourusername@hadoop03.dyndns.org 'cat >> .ssh/authorized_keys'
  
 
  ssh yourusername@hadoop04.dyndns.org mkdir -p .ssh
 
  ssh yourusername@hadoop04.dyndns.org mkdir -p .ssh
−
  cat ~/.ssh/id_rsa.mpi.pub | ssh yourusername@hadoop04.dyndns.org 'cat >> .ssh/authorized_keys'
+
  cat ~/.ssh/id_rsa.pub | ssh yourusername@hadoop04.dyndns.org 'cat >> .ssh/authorized_keys'
 
</source>
 
</source>
 
<br />
 
<br />
Line 62: Line 71:
 
  alias hadoop04='ssh -Y yourusername@hadoop04.dyndns.org'
 
  alias hadoop04='ssh -Y yourusername@hadoop04.dyndns.org'
 
   
 
   
−
* Then tell bash to re-read this setup file, since we just modified it.  This way bash will learn the 3 new aliases we've defined.
+
* Then tell bash to re-read the .bashrc file, since we just modified it.  This way bash will learn the 3 new aliases we've defined.
 
   
 
   
 
  source ~/.bashrc
 
  source ~/.bashrc
 
   
 
   
−
* Now just connect to the servers using their name only.  For example:
+
* Now you should be able to connect to the servers using their name only.  For example:
 
   
 
   
 
  hadoop02       
 
  hadoop02       
Line 72: Line 81:
 
: this should connect you to '''hadoop02''' directly.  
 
: this should connect you to '''hadoop02''' directly.  
 
* Exit from hadoop02, and try the same thing for '''hadoop03''', and '''hadoop04'''.
 
* Exit from hadoop02, and try the same thing for '''hadoop03''', and '''hadoop04'''.
−
 
+
* Note, if you like even shorter commands, you could modify the .bashrc file and make the aliases h2, h3, and h4...  Up to you.
 
   
 
   
 
<br />
 
<br />
  
−
=Test MPI=
+
=Create HelloWorld Program &amp; Test MPI=
 
<br />
 
<br />
−
MPI should already be installed, and your account ready to access it.  To verify this, create a simple MPI "Hello World!" program, compile it, and run it.
+
[[Image:MPIHapoopClusterStep2.png|600px|center]]
 +
<br />
 +
 
 +
MPI should already be installed, and your account ready to access it.  To verify this, you will create an MPI directory and create a simple MPI "Hello World!" program in it.  You will then compile it, and run it as an MPI application.
 +
 
 +
* First create a directory called '''mpi'''
 +
 +
cd
 +
mkdir mpi
 +
 +
* Then '''cd''' to this directory and create the following C program:
 +
 +
cd mpi
 +
emacs -nw helloWorld.c
 +
 +
:Here's the code:
 
<br />
 
<br />
 
::<source lang="C">
 
::<source lang="C">
−
/* C Example */
+
// hello.c
 +
// A simple hello world MPI program that can be run
 +
// on any number of computers
 +
#include <mpi.h>
 
#include <stdio.h>
 
#include <stdio.h>
−
#include <mpi.h>
 
  
 +
int main( int argc, char *argv[] ) {
 +
  int rank, size, nameLen;
 +
  char hostName[80];
  
−
int main (argc, argv)
+
  MPI_Init( &argc, &argv);  /* start MPI */
−
    int argc;
+
  MPI_Comm_rank( MPI_COMM_WORLD, &rank );   /* get current process Id */
−
    char *argv[];
+
  MPI_Comm_size( MPI_COMM_WORLD, &size );  /* get # of processes */
−
{
+
   MPI_Get_processor_name( hostName, &nameLen);
−
   int rank, size;
 
  
−
  MPI_Init (&argc, &argv);      /* starts MPI */
+
   printf( "Hello from Process %d of %d on Host %s\n", rank, size, hostName );
−
  MPI_Comm_rank (MPI_COMM_WORLD, &rank);        /* get current process id */
 
−
  MPI_Comm_size (MPI_COMM_WORLD, &size);        /* get number of processes */
 
−
   printf( "Hello world from process %d of %d\n", rank, size );
 
 
   MPI_Finalize();
 
   MPI_Finalize();
 
   return 0;
 
   return 0;
Line 102: Line 127:
 
</source>
 
</source>
 
<br />
 
<br />
−
* Compile and Run
+
=Compile & Run on 1 Server=
 +
<br />
 +
[[Image:MPIHapoopClusterStep3.png|600px|center]]
 
<br />
 
<br />
  
 +
* Compile and Run the program:
 +
<br />
 +
 
  '''mpicc -o hello helloWorld.c'''
 
  '''mpicc -o hello helloWorld.c'''
 
  '''mpirun -np 2 ./hello'''
 
  '''mpirun -np 2 ./hello'''
−
  Hello world from process 0 of 2
+
  Hello from Process 1 of 2 on Host Hadoop01
−
  Hello world from process 1 of 2
+
  Hello from Process 0 of 2 on Host Hadoop01
−
 
+
 
* If you see the two lines starting with "Hello world" on your screen, MPI was successfully installed on your system!
 
* If you see the two lines starting with "Hello world" on your screen, MPI was successfully installed on your system!
  
Line 131: Line 161:
 
  for i in 1 2 3 4 ; do dig +short hadoop0${i}.dyndns.org ; done > hosts
 
  for i in 1 2 3 4 ; do dig +short hadoop0${i}.dyndns.org ; done > hosts
  
 +
</onlysmith>
 +
=Running HelloWorld.c on all Four Servers=
 +
<br />
 +
==Rsync Your Files to Other Servers==
 +
<br />
 +
[[Image:MPIHapoopClusterStep4.png|600px|center]]
 +
<br />
 +
<tanbox>
 +
'''Important Note''': Every time you create a new program on Hadoop01, you will need to replicate it on the other 3 servers.  This is something that is easily forgotten, so make a mental note to always copy your latest files to the other 3 servers.
 +
</tanbox>
 +
<br />
 +
* One powerful command to copy files remotely is '''rsync''':
 
   
 
   
−
</onlysmith>
+
cd
 +
cd mpi
 +
rsync -azv *  yourusername@hadoop02.dyndns.org:mpi/
 +
rsync -azv *  yourusername@hadoop03.dyndns.org:mpi/
 +
rsync -azv *  yourusername@hadoop04.dyndns.org:mpi/
 +
 +
* Or, if you like bash for-loops:
 +
 +
cd
 +
cd mpi
 +
for i in 2 3 4 ; do rsync -azv * yourusername@hadoop0${i}.dyndns.org:mpi/ ; done
 +
 +
* You are now ready to run '''hello''' on all four servers:
 +
 +
<br />
 +
==Running on All Four Servers==
 +
<br />
 +
[[Image:MPIHapoopClusterStep5.png|600px|center]]
 +
<br />
 +
* Enter the following command:
 +
 +
'''mpirun -np 4 --hostfile hosts ./hello'''
 +
Hello from Process 0 of 4 on Host Hadoop01
 +
Hello from Process 3 of 4 on Host Hadoop04
 +
Hello from Process 2 of 4 on Host Hadoop03
 +
Hello from Process 1 of 4 on Host Hadoop02
 +
 
 +
* And try running 10 processes on 4 servers:
 +
 +
'''mpirun -np 10 --hostfile hosts ./hello'''
 +
Hello from Process 3 of 10 on Host Hadoop04
 +
Hello from Process 7 of 10 on Host Hadoop04
 +
Hello from Process 1 of 10 on Host Hadoop02
 +
Hello from Process 5 of 10 on Host Hadoop02
 +
Hello from Process 9 of 10 on Host Hadoop02
 +
Hello from Process 2 of 10 on Host Hadoop03
 +
Hello from Process 6 of 10 on Host Hadoop03
 +
Hello from Process 0 of 10 on Host Hadoop01
 +
Hello from Process 8 of 10 on Host Hadoop01
 +
Hello from Process 4 of 10 on Host Hadoop01
 +
 
 +
 
 
<br />
 
<br />
 
<br />
 
<br />
Line 148: Line 231:
 
<br />
 
<br />
 
<br />
 
<br />
−
[[Category:MPI]][[Category:CSC352]]
+
[[Category:MPI]][[Category:C]][[Category:CSC352]]

Latest revision as of 13:16, 23 March 2017

--D. Thiebaut (talk) 13:57, 15 October 2013 (EDT)
Revised: --D. Thiebaut (talk) 12:02, 15 March 2017 (EDT)



Change your Password


  • Login to hadoop01 with the accounts provided to you, and change your temporary password:
 passwd
  • You should now be all set.


Setup Password-Less ssh to the Hadoop cluster


MPIHapoopClusterStep1.png



This section is only visible to computers located at Smith College


Setup Aliases


  • This section is not required, but will save you a lot of typing.
  • Edit your .bashrc file 
 emacs -nw ~/.bashrc
  • and add these 3 lines at the end, where you will replace yourusername by your actual user name.
alias hadoop02='ssh -Y yourusername@hadoop02.dyndns.org'
alias hadoop03='ssh -Y yourusername@hadoop03.dyndns.org'
alias hadoop04='ssh -Y yourusername@hadoop04.dyndns.org'
  • Then tell bash to re-read the .bashrc file, since we just modified it. This way bash will learn the 3 new aliases we've defined.
source ~/.bashrc
  • Now you should be able to connect to the servers using their name only. For example:
hadoop02
this should connect you to hadoop02 directly.
  • Exit from hadoop02, and try the same thing for hadoop03, and hadoop04.
  • Note, if you like even shorter commands, you could modify the .bashrc file and make the aliases h2, h3, and h4... Up to you.


Create HelloWorld Program & Test MPI


MPIHapoopClusterStep2.png


MPI should already be installed, and your account ready to access it. To verify this, you will create an MPI directory and create a simple MPI "Hello World!" program in it. You will then compile it, and run it as an MPI application.

  • First create a directory called mpi
cd
mkdir mpi
  • Then cd to this directory and create the following C program:
cd mpi
emacs -nw helloWorld.c
Here's the code:


// hello.c
// A simple hello world MPI program that can be run 
// on any number of computers
#include <mpi.h>
#include <stdio.h>

int main( int argc, char *argv[] ) {
  int rank, size, nameLen;
  char hostName[80];

  MPI_Init( &argc, &argv);   /* start MPI */
  MPI_Comm_rank( MPI_COMM_WORLD, &rank );   /* get current process Id */
  MPI_Comm_size( MPI_COMM_WORLD, &size );   /* get # of processes */
  MPI_Get_processor_name( hostName, &nameLen);

  printf( "Hello from Process %d of %d on Host %s\n", rank, size, hostName );
  MPI_Finalize();
  return 0;
}


Compile & Run on 1 Server


MPIHapoopClusterStep3.png


  • Compile and Run the program:


mpicc -o hello helloWorld.c
mpirun -np 2 ./hello
Hello from Process 1 of 2 on Host Hadoop01
Hello from Process 0 of 2 on Host Hadoop01
  • If you see the two lines starting with "Hello world" on your screen, MPI was successfully installed on your system!


Configuration for Running On Multiple Servers


This section is only visible to computers located at Smith College

Running HelloWorld.c on all Four Servers


Rsync Your Files to Other Servers


MPIHapoopClusterStep4.png


Important Note: Every time you create a new program on Hadoop01, you will need to replicate it on the other 3 servers. This is something that is easily forgotten, so make a mental note to always copy your latest files to the other 3 servers.


  • One powerful command to copy files remotely is rsync:
cd 
cd mpi
rsync -azv *  yourusername@hadoop02.dyndns.org:mpi/
rsync -azv *  yourusername@hadoop03.dyndns.org:mpi/
rsync -azv *  yourusername@hadoop04.dyndns.org:mpi/
  • Or, if you like bash for-loops:
cd
cd mpi
for i in 2 3 4 ; do rsync -azv * yourusername@hadoop0${i}.dyndns.org:mpi/ ; done
  • You are now ready to run hello on all four servers:


Running on All Four Servers


MPIHapoopClusterStep5.png


  • Enter the following command:
mpirun -np 4 --hostfile hosts ./hello
Hello from Process 0 of 4 on Host Hadoop01
Hello from Process 3 of 4 on Host Hadoop04
Hello from Process 2 of 4 on Host Hadoop03
Hello from Process 1 of 4 on Host Hadoop02
  • And try running 10 processes on 4 servers:
mpirun -np 10 --hostfile hosts ./hello
Hello from Process 3 of 10 on Host Hadoop04
Hello from Process 7 of 10 on Host Hadoop04
Hello from Process 1 of 10 on Host Hadoop02
Hello from Process 5 of 10 on Host Hadoop02
Hello from Process 9 of 10 on Host Hadoop02
Hello from Process 2 of 10 on Host Hadoop03
Hello from Process 6 of 10 on Host Hadoop03
Hello from Process 0 of 10 on Host Hadoop01
Hello from Process 8 of 10 on Host Hadoop01
Hello from Process 4 of 10 on Host Hadoop01

















Retrieved from "http://dominiquethiebaut.com/dftwiki3/index.php?title=Tutorial:_Running_MPI_Programs_on_Hadoop_Cluster&oldid=30374"