Fixed a bug with update stream serialization where different reducers where writting to the same files

Author: ArnauPrat

src/main/java/ldbc/snb/datagen/hadoop/HadoopUpdateStreamSorterAndSerializer.java

@@ -52,10 +52,10 @@ public void reduce(UpdateEventKey key, Iterable<Text> valueSet,Context context)
 			try {
 				FileSystem fs = FileSystem.get(conf);
 				if(  compressed ) {
-					Path outFile = new Path(context.getConfiguration().get("ldbc.snb.datagen.serializer.socialNetworkDir")+"/updateStream_"+reducerId+"_"+key.partition+"_"+streamType+".csv.gz");
+					Path outFile = new Path(context.getConfiguration().get("ldbc.snb.datagen.serializer.socialNetworkDir")+"/updateStream_"+key.reducerId+"_"+key.partition+"_"+streamType+".csv.gz");
 					out = new GZIPOutputStream( fs.create(outFile));
 				} else {
-					Path outFile = new Path(context.getConfiguration().get("ldbc.snb.datagen.serializer.socialNetworkDir")+"/updateStream_"+reducerId+"_"+key.partition+"_"+streamType+".csv");
+					Path outFile = new Path(context.getConfiguration().get("ldbc.snb.datagen.serializer.socialNetworkDir")+"/updateStream_"+key.reducerId+"_"+key.partition+"_"+streamType+".csv");
 					out = fs.create(outFile);
 				}
 				for( Text t : valueSet ) {