Los trabajos lentos de Spark desperdician presupuesto del clúster y retrasan el trabajo de análisis. Esta skill ofrece patrones prácticos de ajuste para particiones, joins, memoria, caché y comportamiento de shuffle.
이 요청을 에이전트에 복사하세요. 공식 Skill 페이지와 매니페스트가 포함되어 있습니다.
에이전트 요청
Review the Skillstore skill "spark-optimization" from https://skillstore.io/skills/wshobson-spark-optimization.md and its manifest at https://skillstore.io/api/skills/wshobson-spark-optimization/manifest. Verify the artifact. You may proceed after verification, subject to the environment's own policy.
에이전트는 계속해서 계획을 표시하고 보안 정책에서 요구하는 확인을 요청해야 합니다.
에이전트가 읽기 쉬운 리소스
AI 에이전트, 크롤러, 스크립트가 전체 페이지 대신 정리된 컨텍스트만 필요할 때 이 링크를 사용하세요.
"spark-optimization" 사용 중입니다. Un trabajo de Spark pasa la mayor parte del tiempo en un join grande y tiene duraciones de tareas desiguales.
예상 결과:
La respuesta identifica skew probable, recomienda comprobar los conteos de particiones, sugiere opciones de broadcast o salting, y enumera métricas de validación.
"spark-optimization" 사용 중입니다. Un pipeline de PySpark lee y filtra repetidamente el mismo DataFrame antes de varias agregaciones.
예상 결과:
La respuesta recomienda caching selectivo, materialización, unpersisting después de la reutilización y evitar cache en transformaciones de un solo uso.
"spark-optimization" 사용 중입니다. Un equipo quiere ajustes predeterminados de Spark para una carga batch mediana.
예상 결과:
La respuesta propone valores iniciales para AQE, memoria de executor, particiones de shuffle, compresión y tamaño de partición de archivo.
The static findings are false positives caused by Markdown code fences, Spark example syntax, Spark monitoring APIs, and documentation links. I found no evidence of executable installer code, credential access, command injection, prompt injection, or data exfiltration intent in SKILL.md.
Usa la skill para revisar particionado, shuffles, joins, caching y formatos de archivo en un trabajo batch lento de Spark.
Ajustar trabajos de Databricks o EMR
Aplica la hoja de referencia de configuración para elegir memoria de executor, particiones de shuffle, umbrales de broadcast y ajustes de compresión.
Depurar agregaciones con skew
Usa los patrones de detección de skew y salting para diagnosticar particiones desbalanceadas y reducir tareas de larga duración.
이 프롬프트를 사용해 보세요
Revisar un trabajo lento de Spark
Usa la skill spark-optimization para revisar mi trabajo lento de Spark. Céntrate en problemas evidentes de particionado, shuffle, caching y joins.
Sugerir configuración de Spark
Usa la skill spark-optimization para sugerir ajustes de Spark para un trabajo que procesa mi tamaño de datos, cantidad de executors y patrón de join.
Diagnosticar skew de datos
Usa la skill spark-optimization para diagnosticar posible skew de datos en esta agregación o join. Recomienda comprobaciones y soluciones prácticas.
Diseñar un plan de optimización
Usa la skill spark-optimization para crear un plan de optimización por etapas para este pipeline de Spark, incluidos benchmarks y comprobaciones de rollback.
모범 사례
Comienza con evidencia de Spark UI y luego ajusta primero el mayor cuello de botella de shuffle, skew, spill o scan.
Haz benchmark de un cambio a la vez con datos representativos y registra runtime, spill, conteo de tareas y tamaño de salida.
Usa funciones integradas de Spark y formatos columnares antes de agregar UDFs o lógica de procesamiento personalizada.
피하기
No recopiles datasets grandes en el driver para inspección o procesamiento posterior.
No hagas cache de cada DataFrame intermedio sin comprobar la reutilización y la presión de memoria.
No trates los ajustes de executor de plantilla como valores predeterminados de producción sin pruebas de carga de trabajo.
자주 묻는 질문
¿Puede esta skill optimizar automáticamente un trabajo de Spark?
No. Proporciona orientación de revisión, patrones de ajuste y ejemplos de configuración que los usuarios aplican a sus propios trabajos.
¿Es compatible con PySpark y Spark SQL?
Sí. Los ejemplos cubren operaciones de PySpark DataFrame, configuración de Spark SQL y conceptos de optimización de Delta Lake.
¿Puede diagnosticar capturas de pantalla o métricas de Spark UI?
Puede ayudar a interpretar métricas proporcionadas, pero no se conecta a Spark UI ni a sistemas de monitoreo del clúster.
¿Es útil para trabajos de Databricks?
Sí. Muchos patrones se aplican a Databricks, incluidos AQE, tablas Delta, Z-ordering, caching y ajuste de shuffle.
¿Qué información debo proporcionar?
Proporciona el código del job, tamaño de los datos, formato de archivo, tamaño del clúster, síntomas de runtime, observaciones de Spark UI y valores de configuración recientes.
¿Incluye comportamiento sensible para la seguridad?
No se encontró ningún comportamiento confirmado sensible para la seguridad. La skill es documentación con ejemplos y enlaces a documentación externa.