File tree Expand file tree Collapse file tree 1 file changed +2
-5
lines changed
src/main/java/org/apache/hadoop/mapred Expand file tree Collapse file tree 1 file changed +2
-5
lines changed Original file line number Diff line number Diff line change @@ -171,11 +171,8 @@ public void revokeSlots() {
171
171
return ;
172
172
}
173
173
174
- int mapSlotsToRevoke = taskTracker .getJobConf ().getInt ("mapred.tasktracker.map.tasks.revoke" , 0 );
175
- int reduceSlotsToRevoke = taskTracker .getJobConf ().getInt ("mapred.tasktracker.reduce.tasks.revoke" , 0 );
176
-
177
- int maxMapSlots = taskTracker .getMaxCurrentMapTasks () - mapSlotsToRevoke ;
178
- int maxReduceSlots = taskTracker .getMaxCurrentReduceTasks () - reduceSlotsToRevoke ;
174
+ int maxMapSlots = 0 ;
175
+ int maxReduceSlots = 0 ;
179
176
180
177
// TODO(tarnfeld): Sanity check that it's safe for us to change the slots.
181
178
// Be sure there's nothing running and nothing in the launcher queue.
You can’t perform that action at this time.
0 commit comments