Merge pull request #382 from ldbc/increase-insert-partitions

Author: szarnyasg

src/main/scala/ldbc/snb/datagen/io/graphs.scala

@@ -121,7 +121,7 @@ object graphs {
           log.info(s"$tpe: Writing snapshot completed")
         }(snapshot.sparkSession)
 
-        val insertSizeFactor = 0.247
+        val insertSizeFactor = 0.33
         val deleteSizeFactor = 0.015
 
         val operations = Map(

tools/emr/submit_datagen_job.py

@@ -23,7 +23,7 @@
     'use_spot': True,
     'master_instance_type': 'r6gd.2xlarge',
     'instance_type': 'r6gd.4xlarge',
-    'sf_ratio': 118.0, # ratio of SFs and machines. a ratio of 250.0 for SF1000 yields 4 machines
+    'sf_ratio': 125.0,  # ratio of SFs and machines. a ratio of 250.0 for SF1000 yields 4 machines
     'platform_version': lib.platform_version,
     'version': lib.version,
     'az': 'us-west-2c',