retry with parallelized input dstream