fixing the default number of parallelism for the non-experimental ver…

…sion
diana-hep · Oct 16, 2017 · 007454e · 007454e
1 parent 0ed4f40
commit 007454e
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/org/dianahep/sparkroot/sparkroot.scala b/src/main/scala/org/dianahep/sparkroot/sparkroot.scala
@@ -118,7 +118,7 @@ package object sparkroot {
       val localOptTreeName = optTreeName  
 
       // parallelize over all the files
-      val r = sqlContext.sparkContext.parallelize(inputPathFiles).
+      val r = sqlContext.sparkContext.parallelize(inputPathFiles, inputPathFiles.size).
         flatMap({pathName =>
           logger.info(s"Opening file $pathName")
           val reader = new RootFileReader(pathName)