Skip to content

Commit

Permalink
Merge pull request #43 from henbox/patch-3
Browse files Browse the repository at this point in the history
Clarify thread comment in EmailValidate example step
  • Loading branch information
keelimbeh authored Nov 5, 2019
2 parents 056c6f7 + 89ce2c9 commit 139d910
Showing 1 changed file with 2 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,7 @@ public long execute() throws SDKException {
final String selectedColumnName = getArgument(0);
final StepColumn selectedColumn = getColumnManager().getColumnByName(selectedColumnName);

// queue up to 1000 threads, for processing BLOCK_SIZE times simultaneously
// queue up to THREAD_SIZE threads, for processing BLOCK_SIZE times simultaneously
final List<Future> futures = new ArrayList<>();
for (long rowId = 0L; rowId < rowCount; rowId++) {
try {
Expand Down Expand Up @@ -254,4 +254,4 @@ private void waitForFutures(final List<Future> futures) throws SDKException {
futures.clear();
}
}
}
}

0 comments on commit 139d910

Please sign in to comment.