// Now wait for the task to be in the running state, only then the
// directories will be created
JobInfo info = wovenClient.getJobInfo(rJob.getID());
Assert.assertNotNull("JobInfo is null", info);
JobID id = rJob.getID();
while (info.runningMaps() != 1) {
Thread.sleep(1000);
info = wovenClient.getJobInfo(id);
}
TaskInfo[] myTaskInfos = wovenClient.getTaskInfo(id);
for (TaskInfo tInfo : myTaskInfos) {