-
Notifications
You must be signed in to change notification settings - Fork 855
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
added logic for map-reduce time-skew heuristic #267
Conversation
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I haven't reviewed the main logic yet. I will review them once you fix the formatting.
@@ -27,11 +27,18 @@ | |||
private String _taskId; | |||
// The successful attempt id | |||
private String _attemptId; | |||
|
|||
public void setTotalTimeMs(long _totalTimeMs, boolean _isTimeDataPresent) { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove leading underscore from the method parameters.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
web/package-lock.json
Outdated
@@ -0,0 +1,8310 @@ | |||
{ |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Remove this file.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
import com.linkedin.drelephant.configurations.heuristic.HeuristicConfigurationData; | ||
import com.linkedin.drelephant.util.Utils; | ||
|
||
import java.util.*; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Please expand each of the imports unless they are more than 5.
} | ||
} | ||
|
||
long wasehi = tasks[5].getTotalRunTimeMs(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Rename these
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Removed
* This Heuristic analyses the skewness in the task input data | ||
*/ | ||
public abstract class GenericSkewHeuristic implements Heuristic<MapReduceApplicationData> { | ||
private static final Logger logger = Logger.getLogger(GenericSkewHeuristic.class); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Fix code formatting!
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
No description provided.