AnalyticDB:Files d'attente prioritaires pour les groupes de ressources de tâches

Prérequis

• Un cluster Enterprise Edition, Basic Edition ou Data Lakehouse Edition AnalyticDB for MySQL est créé.

• La version du noyau de votre cluster doit être la 3.1.6.3 ou une version ultérieure.

  Remarque

  Pour afficher et mettre à jour la version mineure, accédez à la section Configuration Information sur la page Cluster Information de la console AnalyticDB for MySQL.

• Vous devez créer et sélectionner un groupe de ressources de tâches lors de la soumission des tâches.

Limites

Vous ne pouvez pas modifier la priorité d'une tâche une fois celle-ci soumise. Cette règle s'applique aux tâches en attente comme aux tâches en cours d'exécution.

Présentation

La priorité d'une tâche détermine l'ordre d'allocation des ressources aux tâches en file d'attente. Lorsque plusieurs tâches s'exécutent simultanément au sein d'un groupe de ressources de tâches, les ressources requises peuvent dépasser les ressources disponibles du groupe. AnalyticDB for MySQL prend en charge la mise en file d'attente des tâches : les nouvelles tâches sont placées en attente plutôt que d'échouer.

Dans certains scénarios métier, l'ordre d'exécution des tâches et de génération des résultats est critique. Par exemple, si la génération de métriques clés dépend du moment de production d'un résultat intermédiaire en amont, vous devez attribuer une priorité élevée à la tâche de traitement en amont afin de garantir qu'elle dispose de ressources suffisantes. AnalyticDB for MySQL propose des files d'attente prioritaires au sein des groupes de ressources de tâches. Vous pouvez définir une priorité pour placer les tâches dans différentes files d'attente, notamment LOWEST, LOW, NORMAL et HIGH. Les tâches dotées d'une priorité plus élevée sont exécutées en premier.

Définir la priorité d'une tâche

/*+ query_priority=HIGH*/ SELECT * FROM test_table;

 SET spark.adb.priority = LOW;
 SELECT * FROM test_table;

{
    "comments": [
        "-- Here is just an example of SparkPi. Modify the content and run your spark program."
    ],
    "args": [
        "1000"
    ],
    "file": "local:///tmp/spark-examples.jar",
    "name": "SparkPi",
    "className": "org.apache.spark.examples.SparkPi",
    "conf": {
        "spark.driver.resourceSpec": "medium",
        "spark.executor.instances": 2,
        "spark.executor.resourceSpec": "medium",
        "spark.adb.priority": "HIGH"
    }
}

Afficher la priorité d'une tâche