Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP

Comparing changes

Choose two branches to see what's changed or to start a new pull request. If you need to, you can also compare across forks.

Open a pull request

Create a new pull request by comparing changes across two branches. If you need to, you can also compare across forks.
base fork: twitter/ambrose
base: a459d2a58f
...
head fork: twitter/ambrose
compare: ab86422ba8
  • 2 commits
  • 2 files changed
  • 0 commit comments
  • 2 contributors
View
2  common/src/main/java/com/twitter/ambrose/model/Event.java
@@ -52,7 +52,7 @@ private Event(Type type, T payload) {
this.payload = payload;
}
- private Event(int eventId, long timestamp, Type type, T payload) {
+ public Event(int eventId, long timestamp, Type type, T payload) {
this.id = eventId;
this.timestamp = timestamp;
this.type = type;
View
5 pig/src/main/java/com/twitter/ambrose/pig/AmbrosePigProgressNotificationListener.java
@@ -175,6 +175,11 @@ public void jobStartedNotification(String scriptId, String assignedJobId) {
*/
@Override
public void jobFailedNotification(String scriptId, JobStats stats) {
+ if (stats.getJobId() == null) {
+ log.warn("jobId for failed job not found. This should only happen in local mode");
+ return;
+ }
+
DAGNode<PigJob> node = dagNodeJobIdMap.get(stats.getJobId());
if (node == null) {
log.warn("Unrecognized jobId reported for failed job: " + stats.getJobId());

No commit comments for this range

Something went wrong with that request. Please try again.