Fixed chunk size issue

Azure · Feb 23, 2017 · d76fbdb · d76fbdb
1 parent 54cbaeb
commit d76fbdb
Showing 1 changed file with 8 additions and 6 deletions.
diff --git a/R/doAzureParallel.R b/R/doAzureParallel.R
@@ -181,12 +181,14 @@ getparentenv <- function(pkgname) {
 
   startIndices <- seq(1, length(argsList), chunkSize)
 
-  if(chunkSize > length(argsList)){
-    endIndices <- seq(length(argsList), length(argsList))
-  }
-  else{
-    endIndices <- seq(chunkSize, length(argsList), chunkSize)
-  }
+  endIndices <-
+    if(chunkSize >= length(argsList))
+    {
+      c(length(argsList))
+    }
+    else {
+      seq(chunkSize, length(argsList), chunkSize)
+    }
 
   minLength <- min(length(startIndices), length(endIndices))