This is an automated email from the ASF dual-hosted git repository. dlych pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 40c55b569577121d3087d286be4c3b102b85a585 Author: Michael Blow <[email protected]> AuthorDate: Mon Jan 18 11:13:48 2021 -0500 [NO ISSUE][HYR] Shorten SuperActivityOperatorNodePushable thread names - Use SA in place of SuperActivityOperatorNodePushable when annotating thread names, for brevity Change-Id: I73b6443492bb872c78f5a1756b124abda9222015 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/9663 Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Ian Maxon <[email protected]> --- .../api/rewriter/runtime/SuperActivityOperatorNodePushable.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivityOperatorNodePushable.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivityOperatorNodePushable.java index 1d8c774..79687ab 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivityOperatorNodePushable.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivityOperatorNodePushable.java @@ -55,7 +55,7 @@ import org.apache.hyracks.api.util.ExceptionUtils; * connected activities in a single thread. */ public class SuperActivityOperatorNodePushable implements IOperatorNodePushable { - private static final String CLASS_SIMPLE_NAME = SuperActivityOperatorNodePushable.class.getSimpleName(); + private static final String CLASS_ABBREVIATION = "SA"; private final Map<ActivityId, IOperatorNodePushable> operatorNodePushables = new HashMap<>(); private final List<IOperatorNodePushable> operatorNodePushablesBFSOrder = new ArrayList<>(); private final Map<ActivityId, IActivity> startActivities; @@ -224,7 +224,7 @@ public class SuperActivityOperatorNodePushable implements IOperatorNodePushable try { Thread.currentThread() .setName(Thread.currentThread().getName() + ":" + ctx.getJobletContext().getJobId() - + ":" + ctx.getTaskAttemptId() + ":" + CLASS_SIMPLE_NAME); + + ":" + ctx.getTaskAttemptId() + ":" + CLASS_ABBREVIATION); action.run(op); } catch (Throwable th) { // NOSONAR: Must catch all causes of failure failures.offer(th);
