Changeset 27589 for gs2-extensions/parallel-building/trunk
- Timestamp:
- 2013-06-10T14:19:21+12:00 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
gs2-extensions/parallel-building/trunk/src/bin/script/parse_task_info_from_hadoop_log.pl
r27588 r27589 173 173 # And job completion... so we can keep parsing other log files as 174 174 # necessary 175 elsif ($line =~ /Job 'job_${job_id} has completed successfully\./)175 elsif ($line =~ /Job job_${job_id} has completed successfully\./) 176 176 { 177 177 $job_complete = 1; … … 213 213 } 214 214 } 215 print " Done\n";215 print " Done\n"; 216 216 217 217 if (!$job_complete) … … 253 253 } 254 254 print CSVOUT $task_number . "," . $attempt_number . "," . $data_local . ",\"" . $compute_node . "\",\"" . join(',', natsort(@splits)) . "\"\n"; 255 undef($tid_2_splits->{$task_id});255 $tid_2_splits->{$task_id} = undef; 256 256 } 257 257 … … 260 260 foreach my $task_id (keys %{$tid_2_splits}) 261 261 { 262 my ($job_id, $task_number) = $task_id =~ /^(\d+_\d+)_m_(\d+)/; 263 my @splits = @{$tid_2_splits->{$task_id}}; 264 print CSVOUT $task_number . ",-1,-1,\"\",\"" . join(',', natsort(@splits)) . "\"\n"; 262 if (defined $tid_2_splits->{$task_id}) 263 { 264 my ($job_id, $task_number) = $task_id =~ /^(\d+_\d+)_m_(\d+)/; 265 my @splits = @{$tid_2_splits->{$task_id}}; 266 print CSVOUT $task_number . ",-1,-1,\"\",\"" . join(',', natsort(@splits)) . "\"\n"; 267 } 265 268 } 266 269
Note:
See TracChangeset
for help on using the changeset viewer.