abdullah alamoudi has uploaded a new change for review.
https://asterix-gerrit.ics.uci.edu/2850
Change subject: [NO ISSUE][ING] Set JobId in thread waiting for job to complete
......................................................................
[NO ISSUE][ING] Set JobId in thread waiting for job to complete
- user model changes: no
- storage format changes: no
- interface changes: no
Details:
- When stopping an active job, set the job Id in the thread to enable
debugging if the job gets stuck.
Change-Id: Ic19d11f150aa404522133d4d7227c758dbf0de6a
---
M
asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
1 file changed, 4 insertions(+), 0 deletions(-)
git pull ssh://asterix-gerrit.ics.uci.edu:29418/asterixdb
refs/changes/50/2850/1
diff --git
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
index b5432c5..22c9b5d 100644
---
a/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
+++
b/asterixdb/asterix-app/src/main/java/org/apache/asterix/app/active/ActiveEntityEventsListener.java
@@ -450,7 +450,9 @@
}
WaitForStateSubscriber subscriber = new WaitForStateSubscriber(this,
waitFor);
// Note: once we start sending stop messages, we can't go back until
the entity is stopped
+ final String nameBefore = Thread.currentThread().getName();
try {
+ Thread.currentThread().setName(nameBefore + " :
WaitForCompletionForJobId: " + jobId);
sendStopMessages(metadataProvider, timeout, unit);
LOGGER.log(Level.DEBUG, "Waiting for its state to become " +
waitFor);
subscriber.sync();
@@ -460,6 +462,8 @@
Thread.currentThread().interrupt();
} catch (Throwable e) {
forceStop(subscriber, e);
+ } finally {
+ Thread.currentThread().setName(nameBefore);
}
}
--
To view, visit https://asterix-gerrit.ics.uci.edu/2850
To unsubscribe, visit https://asterix-gerrit.ics.uci.edu/settings
Gerrit-MessageType: newchange
Gerrit-Change-Id: Ic19d11f150aa404522133d4d7227c758dbf0de6a
Gerrit-PatchSet: 1
Gerrit-Project: asterixdb
Gerrit-Branch: master
Gerrit-Owner: abdullah alamoudi <[email protected]>
