This is an automated email from the ASF dual-hosted git repository. imaxon pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit 40be6e72254ea9a2192041eb357435bc838dee93 Author: Michael Blow <[email protected]> AuthorDate: Tue Apr 13 17:28:31 2021 -0400 [NO ISSUE][HYR] Increase thread name brevity Change-Id: I55a7586980cf869edd383ab435952f10b3976b86 Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/11045 Integration-Tests: Jenkins <[email protected]> Tested-by: Jenkins <[email protected]> Reviewed-by: Michael Blow <[email protected]> Reviewed-by: Murtadha Hubail <[email protected]> --- .../org/apache/hyracks/api/rewriter/runtime/SuperActivity.java | 5 +++++ .../api/rewriter/runtime/SuperActivityOperatorNodePushable.java | 7 +++---- 2 files changed, 8 insertions(+), 4 deletions(-) diff --git a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java index ddcfd78..55eaf68 100644 --- a/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java +++ b/hyracks-fullstack/hyracks/hyracks-api/src/main/java/org/apache/hyracks/api/rewriter/runtime/SuperActivity.java @@ -54,6 +54,11 @@ public class SuperActivity extends OneToOneConnectedActivityCluster implements I } @Override + public String getDisplayName() { + return "SA"; + } + + @Override public IOperatorNodePushable createPushRuntime(IHyracksTaskContext ctx, final IRecordDescriptorProvider recordDescProvider, final int partition, final int nPartitions) throws HyracksDataException { 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 79687ab..e43d72a 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_ABBREVIATION = "SA"; + private static final String CLASS_ABBREVIATION = "SAO"; private final Map<ActivityId, IOperatorNodePushable> operatorNodePushables = new HashMap<>(); private final List<IOperatorNodePushable> operatorNodePushablesBFSOrder = new ArrayList<>(); private final Map<ActivityId, IActivity> startActivities; @@ -222,9 +222,8 @@ public class SuperActivityOperatorNodePushable implements IOperatorNodePushable tasks.add(ctx.getExecutorService().submit(() -> { startSemaphore.release(); try { - Thread.currentThread() - .setName(Thread.currentThread().getName() + ":" + ctx.getJobletContext().getJobId() - + ":" + ctx.getTaskAttemptId() + ":" + CLASS_ABBREVIATION); + Thread.currentThread().setName(CLASS_ABBREVIATION + ":" + ctx.getJobletContext().getJobId() + + ":" + ctx.getTaskAttemptId()); action.run(op); } catch (Throwable th) { // NOSONAR: Must catch all causes of failure failures.offer(th);
