diff options
| -rw-r--r-- | P1/src/mapreduce.c | 3 |
1 files changed, 1 insertions, 2 deletions
diff --git a/P1/src/mapreduce.c b/P1/src/mapreduce.c index 1f0b2bb..50ca5ca 100644 --- a/P1/src/mapreduce.c +++ b/P1/src/mapreduce.c @@ -27,7 +27,7 @@ int main(int argc, char *argv[]) { pid_t mapperPid; - for (int i = 0; i < nMappers; i++) { + for (int i = 1; i < nMappers; i++) { mapperPid = fork(); if (mapperPid > 0) { //TODO: exec here @@ -57,7 +57,6 @@ int main(int argc, char *argv[]) { pid_t reducerPid; for (int i = 0; i < nReducers; i++) { - if (pid == 0) reducerPid = fork(); if (reducerPid > 0) { //TODO: exec here |