This article introduces the background pain points, core value, and usage guide of the EMR Agent queue diagnostics capability, helping operations teams quickly assess the availability, resource pressure, job status, and recent change impact of EMR Serverless queues.
In daily operations of EMR Serverless, queues are the core objects for job submission, resource quotas, and compute group scheduling. Queue issues typically directly affect job startup, operational efficiency, and business stability, but manual troubleshooting presents the following pain points:
Queue issues often involve queue status, compute group status, CPU/memory/GPU quotas, job distribution, shuffle pressure, and recent configuration changes simultaneously. Operations personnel need to repeatedly switch between the console, monitoring, job lists, and operation records to piece together the complete context.
The meanings of fields such as public queues, exclusive queues, fixed resources, elastic resources, compute group MinCU/MaxCU, AssignedCU, GPU/MGPU, and others differ. Relying on a single configuration item or a single monitoring curve can easily lead to misjudging normal resource states as abnormal.
Job failures, slow submission, slow execution, and queue waiting may result from insufficient queue resources, unavailable target compute groups, unreasonable job parameters, SQL/code issues, or recent change failures. Manual troubleshooting requires combining multiple types of evidence for judgment, with a high experience threshold.
Different personnel may describe the risks of the same type of queue with varying granularity, conclusion priorities, and handling suggestions, causing troubleshooting closure to depend on individual experience and making it difficult to establish a unified operations process.
EMR Agent queue diagnostics is designed for EMR Serverless queue scenarios. After the user provides the queue ID, the Agent automatically collects basic queue information, compute group configuration, resource monitoring, recent jobs, and evidence of abnormal operations, and generates a structured diagnostic report.
The queue diagnostics primarily address the following questions:
tip
Core value: Automatically collect queue context · Aggregate resource and job evidence · Identify capacity and scheduling risks · Output standardized handling recommendations
Queue diagnostics are suitable for the following use cases:
For example, jobs are stuck in submission or resource initialization, or the number of running jobs is abnormal, leading to the suspicion of insufficient queue resources or unavailable target compute groups.
For example, sustained high allocation or utilization rates of CPU, memory, GPU, or MGPU, requiring assessment of whether to scale out, adjust quotas, or optimize job resource parameters.
For example, multiple job failures occur within a short period in the same queue, requiring differentiation between queue-side resource or scheduling issues and job-specific SQL, code, or parameter issues.
For example, a Spark, Presto, Ray, or general compute group is unavailable, has insufficient configuration, or has an unreasonable waiting strategy, affecting jobs of the corresponding type.
For example, after scaling, creating or deleting compute groups, suspending, or releasing operations, it is necessary to confirm whether the changes affect queue availability and job execution.
For example, to quickly understand the resource usage, main resource consumers, and potential optimization points of a queue over a period of time.
Before using queue diagnostics, confirm the following:
EMR Agent queue diagnostics provides three common entry points.
Go to the Serverless → Queue Resources page, and click AI Diagnostics in the row of the target queue. This entry point will directly redirect to EMR Agent and automatically carry over the current queue context. It is suitable for quickly initiating diagnostics from the queue inspection, resource list, or routine operations pages.
After entering the EMR Agent Assistant, you can directly describe your diagnostic request in the input box and provide the target queue ID.
Common question formats:
帮我看一下 1547635987612434432 这个 Serverless 队列最近是否有资源瓶颈 这个队列最近作业提交很慢,帮我判断是不是资源不足:队列ID 1547635987612434432 帮我诊断一下队列 1547635987612434432
After entering the EMR Agent Assistant, click Resource Diagnostics on the homepage, and select Serverless Queue Diagnostics from the dropdown menu. The system will display the queue diagnostics form. Fill in the queue information as required and submit the form.
Step 1: Select a diagnostic entry point
You can initiate diagnostics from the AI Diagnostics button in the queue resource list, or enter EMR Agent Assistant to initiate via natural language or the resource diagnostics form.
Step 2: Wait for the Agent to automatically collect and analyze data
The Agent will automatically retrieve basic queue information, compute group information, monitoring summaries, recent jobs, and evidence of abnormal operations, then generate a queue diagnostics report. There is no need to manually switch between multiple systems to collect context during the diagnostic process.
Step 3: View the diagnostic results
After diagnostics are complete, you can view the report summary in the current session or go to the report details to see the full diagnostic content. The report is organized into modules such as anomaly insights, resource analysis, and health assessment, making it easy to quickly locate issues and take action.
The queue diagnostics report typically includes the following modules:
Module | Note |
|---|---|
Exception insight | Display clear exceptions or risks that require user attention, such as queue unavailability, compute group exceptions, sustained high resource usage, recent failed operations, or concentrated failed jobs. |
Resource analysis | Analyze queue pressure by combining resource utilization, resource trends, task throughput, task execution status, queue capacity, compute group configuration, Shuffle, and key resource consumers. |
Health assessment | Provide the queue health level, such as healthy, needs attention, or exception, and specify the impact scope and actionable recommendations. |
Deep analysis summary | When "Deep analysis" is enabled, further explain the relationships among queue configuration, monitoring, jobs, and operation records. |
When reading the report, it is recommended to focus on the following first: