topic Re: MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH in Intel® oneAPI Math Kernel Library

MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH

amolins — Fri, 09 Oct 2009 22:57:14 GMT

The following code has proved good to generate a crash using MKL 10.2 update 2 (sequential version and threaded), last revision of MVAPICH, in two different clusters. Can anybody tell me what the problem is here? It does not crash always, but it does crash when the right number of MPI processes and matrix sizes are selected.

* crash.cpp - crashes with ICC 11.1, MKL 10.2, MVAPICH 1.0 on linux 64-bit

* both linked with the serial or threaded libraries

* doing mpirun -np 36 crash 5000 10

#include

#include "mpi.h"

#include "mkl_scalapack.h"

extern "C" {

/* BLACS C interface */

void Cblacs_get( int context, int request, int* value);

int Cblacs_gridinit( int* context, char * order, int np_row, int np_col);

void Cblacs_gridinfo( int context, int* np_row, int* np_col, int* my_row, int* my_col);

int numroc_( int *n, int *nb, int *iproc, int *isrcproc, int *nprocs);

/* PBLAS */

void pdgemm_( char *TRANSA, char *TRANSB, int * M, int * N, int * K, double * ALPHA,

double * A, int * IA, int * JA, int * DESCA, double * B, int * IB, int * JB, int * DESCB,

double * BETA, double * C, int * IC, int * JC, int * DESCC );

}

#define BLOCK_SIZE 65

int main( int argc, char* argv[] )

{

int iam, nprocs;

MPI_Init(&argc,&argv); /* starts MPI */

MPI_Comm_rank(MPI_COMM_WORLD, &iam);

MPI_Comm_size(MPI_COMM_WORLD, &nprocs);

// get done with the ones that are not part of the grid

int blacs_pgrid_size = floor(sqrt(nprocs));

if (iam>=blacs_pgrid_size*blacs_pgrid_size) {

printf("Bye bye world from process %d of %d. BLACS had no place for me...\n",iam,nprocs);

MPI_Finalize();

}

// start BLACS with square processor grid

if(iam==0)

printf("starting BLACS...");

int ictxt,nprow,npcol,myrow,mycol;

Cblacs_get( -1, 0, &ictxt );

Cblacs_gridinit( &ictxt, "C", blacs_pgrid_size, blacs_pgrid_size );

Cblacs_gridinfo( ictxt, &nprow, &npcol, &myrow, &mycol );

if(iam==0)

printf("done.\n");

double timing;

int m,n,k,lm,ln,nbm,nbn,rounds;

int myzero=0,myone=1;

sscanf(argv[1],"%d",&m);

n=m;

k=m;

sscanf(argv[2],"%d",&rounds);

nbm = BLOCK_SIZE;

nbn = BLOCK_SIZE;

lm = numroc_(&m, &nbm, &myrow, &myzero, &nprow);

ln = numroc_(&n, &nbn, &mycol, &myzero, &npcol);

int info;

int *ipiv = new int[lm+nbm+10000000]; //adding a "little" bit of extra space just in case

char ta = 'N',tb = 'T';

double alpha = 1.0, beta = 0.0;

double* test1data = new double[lm*ln];

double* test2data = new double[lm*ln];

double* test3data = new double[lm*ln];

for(int i=0;i

test1data=(double)(rand()%100)/10000.0;

int *test1desc = new int[9];

int *test2desc = new int[9];

int *test3desc = new int[9];

test1desc[0] = 1; // descriptor type

test1desc[1] = ictxt; // blacs context

test1desc[2] = m; // global number of rows

test1desc[3] = n; // global number of columns

test1desc[4] = nbm; // row block size

test1desc[5] = nbn; // column block size (DEFINED EQUAL THAN ROW BLOCK SIZE)

test1desc[6] = 0; // initial process row(DEFINED 0)

test1desc[7] = 0; // initial process column (DEFINED 0)

test1desc[8] = lm; // leading dimension of local array

memcpy(test2desc,test1desc,9*sizeof(int));

memcpy(test3desc,test1desc,9*sizeof(int));

for(int iter=0;iter

{

if(iam==0)

printf("iter %i - ",iter);

//test2 = test1

memcpy(test2data,test1data,lm*ln*sizeof(double));

//test3 = test1*test2

timing=MPI_Wtime();

pdgemm_(&ta,&tb,&m,&n,&k,

α,

test1data,&myone,&myone,test1desc,

test2data,&myone,&myone, test2desc,

β,

test3data,&myone,&myone, test3desc);

if(iam==0)

printf(" PDGEMM = %f |",MPI_Wtime()-timing);

//test3 = LU(test3)

timing=MPI_Wtime();

pdgetrf_(&m, &n, test3data, &myone, &myone, test3desc, ipiv, &info);

if(iam==0)

printf(" PDGETRF = %f.\n",MPI_Wtime()-timing);

}

delete[] ipiv;

delete[] test1data, test2data, test3data;

delete[] test1desc, test2desc, test3desc;

MPI_Finalize();

return 0;

}

Re: MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH

Gennady_F_Intel — Sun, 11 Oct 2009 07:16:49 GMT

A,
can you check the problem with another MPI like MPICH v 1.2.x or MPICH2 v.1.1.x officially validated by Intel MKL?
what is your linking line? Please check the Linker Adviser:" http://software.intel.com/en-us/articles/intel-mkl-link-line-advisor/"
--Gennady

Re: MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH

amolins — Wed, 14 Oct 2009 21:31:53 GMT

Quoting - Gennady Fedorov (Intel)

Now, do you have access to any MKL's ScaLAPACK benchmark? I am getting an efficiency of roughly 40% when doing the benchmarking of DGEMM, DGETRF/DGETRI, and DPOTRF/DPOTRI. Is that normal?

Re: MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH

amolins — Wed, 14 Oct 2009 22:19:19 GMT

Quoting - amolins@mit.edu

I tried with the last MVAPICH (MPICH is WAY slower than that), and did manage to get it to fail with the last release, 1.1. It does work with the nightly build of 2009-10-09, so I will claim it was MAVPICH library fault.

Now, do you have access to any MKL's ScaLAPACK benchmark? I am getting an efficiency of roughly 40% when doing the benchmarking of DGEMM, DGETRF/DGETRI, and DPOTRF/DPOTRI. Is that normal?

A

my linking line isMKL_LNK = $(MKLPATH)/libmkl_scalapack_lp64.a -Wl,--start-group $(MKLPATH)/libmkl_intel_lp64.a $(MKLPATH)/libmkl_sequential.a $(MKLPATH)/libmkl_core.a $(MKLPATH)/libmkl_blacs_lp64.a -Wl,--end-group -lpthread

this is 64-bit Linux.

I just made the same program crash again by exploring the parameter space carefully. Matrix side 10000 makes the thing crash for 36 cores.

Are you saying that MVAPICH is not supported? How can I use Infiniband then?

Re: MKL ScaLAPACK + MVAPICH + 100 lines of code = CRASH

Gennady_F_Intel — Fri, 16 Oct 2009 08:31:41 GMT

Now, do you have access to any MKL's ScaLAPACK benchmark? I am getting an efficiency of roughly 40% when doing the benchmarking of DGEMM, DGETRF/DGETRI, and DPOTRF/DPOTRI. Is that normal?No, we don't provide the access to this benchmark.
You are getting 40% of efficiency on 36 cores with the matrix size 10000. This is expected result. Please check the efficiency for 8 or 16 cores? It should be better.

Are you saying that MVAPICH is not supported? How can I use Infiniband then?
another MPI versions like OpenMPI, Intel MPI support Infiniband

--Gennady