change StepExecutionRunner.collectorData from ArrayBlockingQueue to LinkedBlockingQueue to avoid capacity overflow; add collector and analyzer to test-apps/chunkPartition and verify max threads of a partitioned step.