Skip to content

Commit 5f00d48

Browse files
committed
Fixed bug with update stream generation when num threads greater than 1
1 parent 049de9c commit 5f00d48

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/main/java/ldbc/socialnet/dbgen/generator/MRGenerateUsers.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -610,9 +610,10 @@ public int runGenerateJob(Configuration conf) throws Exception {
610610
max = auxMax > max ? auxMax : max;
611611
numEvents += Long.parseLong(properties.getProperty("num_events"));
612612
}
613-
613+
file.close();
614+
file = fs.open(new Path(conf.get("outputDir") + "/social_network/updateStream_" + i + "_" + j + "_forum.properties"));
615+
properties.load(file);
614616
if( properties.getProperty("min_write_event_start_time") != null ) {
615-
properties.load(fs.open(new Path(conf.get("outputDir") + "/social_network/updateStream_" + i + "_" + j + "_forum.properties")));
616617
Long auxMin = Long.parseLong(properties.getProperty("min_write_event_start_time"));
617618
min = auxMin < min ? auxMin : min;
618619
Long auxMax = Long.parseLong(properties.getProperty("max_write_event_start_time"));

0 commit comments

Comments
 (0)