Temporaly disabled removing of temporal update streams

Author: ArnauPrat

src/main/java/ldbc/snb/datagen/generator/LDBCDatagen.java

@@ -179,13 +179,13 @@ public int runGenerateJob(Configuration conf) throws Exception {
             HadoopUpdateStreamSorterAndSerializer updateSorterAndSerializer = new HadoopUpdateStreamSorterAndSerializer(conf);
             updateSorterAndSerializer.run(personStreamsFileNames, "person");
             updateSorterAndSerializer.run(forumStreamsFileNames, "forum");
-            for(String file : personStreamsFileNames) {
+            /*for(String file : personStreamsFileNames) {
                 fs.delete(new Path(file), true);
             }
 
             for(String file : forumStreamsFileNames) {
                 fs.delete(new Path(file), true);
-            }
+            }*/
 
             /*for( int i = 0; i < DatagenParams.numThreads; ++i) {
                 int numPartitions = conf.getInt("ldbc.snb.datagen.serializer.numUpdatePartitions", 1);

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

@@ -15,6 +15,6 @@ public HadoopUpdateEventKeyPartitioner() {
 
     @Override
     public int getPartition(UpdateEventKey key, Text text, int numReduceTasks) {
-        return (int)(key.reducerId);
+        return (key.reducerId);
     }
 }