-
Notifications
You must be signed in to change notification settings - Fork 177
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
adding the cancel method for Hive, HadoopJava, Pig #201
Conversation
@@ -22,12 +22,15 @@ | |||
import java.io.IOException; |
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.
Should we make this change for reportalpig and reportalhive as well ?
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.
Reportal's pig and hive seem to use a completely different code base.
We can do it, but I don't think should be in this pull request.
In addition, I think pig and hive are mostly cleaning up after themselves already, so this PR's most material impact would be on hadoopJava processes
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.
make sense. We can open a github bug to track it and handle reportal changes separately.
incorporated feedback. Please check again. Thanks! |
@Override | ||
public Void run() throws Exception { | ||
HadoopJobUtils.killAllSpawnedHadoopJobs(logFilePath, log); | ||
return null; |
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.
nit - can be removed.
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.
um...not having this line actually causes a compile error, hence I had to add it in in the first place.
LGTM |
LGTM. Can you rebase squash the commits before merging? Thanks! |
Refactoring of common methods into HadoopSecureWrapperUtils Allowing users to specify global job properties using reportal variables
…ception when exception throws when hdfs viewer opens a specific file.
adding the cancel method for Hive, HadoopJava, Pig
@johnyu0520 - One thing I might have failed to mention in my rebase instructions in azkaban/azkaban#517 is that in order to squash your commits, once One other thing you can do is you can edit the commit message for your squashed commit. To do that, just use |
@davidzchen My observation is that rebasing does not work well for
For this patch, I was fortunate to get away with git rebase -i (which I do use from time to time over the yeras). In the normal case where commits don't drag out for that long, this process is indeed pretty light weight |
Thanks, @johnyu0520! I really appreciate you taking the time to for doing the rebase. Sorry for the hassle. The reason why I am suggesting that we rebase and squash commits for pull requests is that this model is closer to the development model followed by Apache projects (i.e. one single patch per issue), and I think it would be great to eventually get Azkaban into Apache. :) Rebasing would definitely result in a lot of merge conflicts if your branch has greatly diverged from master. I found that it becomes much easier to do development in a feature branch (as discussed in azkaban/azkaban#517) and rebase and squash commits as often as possible, such as whenever new changes land in master. That way, there would not suddenly be a ton of merge conflicts when rebasing rebase because the feature branch would not have diverged very far from master. |
so that it kills the hadoop job that it launches