Démarrer un déploiement Flink - Realtime Compute for Apache Flink

Après avoir créé un déploiement, vous devez le démarrer depuis la page Deployments. Le démarrage est également nécessaire pour reprendre un déploiement arrêté ou pour appliquer des mises à jour de paramètres qui exigent un redémarrage.

Prérequis

Un déploiement existant est requis. Pour plus d'informations, consultez la rubrique Créer un déploiement.

Limites

Vous ne pouvez spécifier des options de démarrage que pour un déploiement en continu (streaming).

Précautions

Si un utilisateur RAM, un rôle RAM ou un autre compte Alibaba Cloud démarre un déploiement, assurez-vous que l'identité correspondante dispose d'un accès au namespace cible. Pour plus d'informations, consultez les rubriques Autoriser l'accès à la console Flink entièrement gérée et Gérer les autorisations.
Lorsque vous démarrez un déploiement en utilisant l'option Latest State ou Specific State, le système effectue une vérification de compatibilité de l'état. Démarrer un déploiement présentant des incompatibilités détectées comporte des risques, car cela peut entraîner un échec ou des résultats inattendus. Pour plus d'informations, consultez la rubrique Référence sur la compatibilité des états Flink.

Procédure

Ouvrez la boîte de dialogue Start pour le déploiement.
1. Connectez-vous à la console Flink entièrement gérée en tant qu'utilisateur disposant du rôle owner pour le namespace.
2. Dans la barre de navigation supérieure, sélectionnez le namespace cible.
3. Sur la page O&M > Deployments, sélectionnez STREAM ou BATCH dans la liste déroulante.
Repérez le déploiement cible et, dans la colonne Actions, cliquez sur Start.

(Facultatif) Pour un déploiement en continu, configurez les options de démarrage.

Initial mode

Sélectionnez ce mode pour un nouveau déploiement ou lorsque vous ne pouvez pas réutiliser un état existant. Selon vos besoins métier, vous pouvez également décider d'activer Autopilot.

Remarque

Le mode Initial constitue un démarrage sans état qui ne réutilise aucun état. Du point de vue d'un connecteur source, il équivaut à un premier démarrage ; par conséquent, les paramètres de position de démarrage configurés dans le DDL s'appliquent à nouveau. Par exemple, si une table source MySQL CDC définit scan.startup.mode sur latest-offset, le déploiement lit uniquement à partir du dernier offset actuel après son démarrage en mode Initial et ne réanalyse pas l'intégralité des données historiques. Si la valeur par défaut initial est conservée, le déploiement réanalyse l'intégralité des données historiques.

Si le stockage en amont impose une limite de rétention des données, telle que la période de rétention des journaux de Simple Log Service (SLS) ou la période de rétention des messages d'une file d'attente de messages, la plage de données relue après un démarrage en mode Initial est contrainte par cette période de rétention et peut différer de la plage de données de la première exécution. Si le sink en aval écrase les données par clé primaire, évaluez la période de rétention des données en amont avant de démarrer le déploiement en mode Initial afin d'éviter des écrasements inattendus dans la table de résultats.

Stratégie

Description

Specify source's start time

Sélectionnez Specify source's start time et saisissez une heure spécifique.

Vous pouvez définir une heure de démarrage dans l'interface utilisateur pour les sept connecteurs suivants : Kafka, Log Service (SLS), DataHub, ApsaraMQ for RocketMQ, Hologres, Paimon et MySQL.

L'heure de lecture des données spécifiée sur l'interface de démarrage du déploiement est prioritaire sur le paramètre startTime défini dans le code DDL du déploiement.

Remarque

Les versions de Kafka antérieures à 0,11 peuvent ne pas être prises en charge en raison d'une incompatibilité potentielle avec la version du client Kafka utilisée par le connecteur. Nous vous recommandons de mettre à niveau votre version de Kafka.
Tous les connecteurs ne prennent pas en charge la configuration du paramètre startTime. Pour plus d'informations, consultez les paramètres WITH de chaque connecteur, tels que les paramètres WITH de Log Service (SLS), afin de vérifier si le paramètre startTime est inclus.
Le paramètre startTime ne prend effet que lors du démarrage d'un nouveau déploiement où ce paramètre est spécifié. Si vous démarrez un déploiement à partir d'un checkpoint ou d'un savepoint, la spécification du paramètre startTime n'a aucun effet.

Configure Autopilot

Activez cette option et sélectionnez un mode d'ajustement :

Mode Autopilot : le système réduit automatiquement les ressources lorsque l'utilisation est faible et les augmente lorsque l'utilisation atteint un certain seuil. Pour plus d'informations, consultez la rubrique Activer et configurer Autopilot.
Mode planifié : vous devez sélectionner une planification dans la liste déroulante. Une planification peut contenir plusieurs configurations de ressources pour différents moments. Vous pouvez configurer les ressources en fonction des modèles d'utilisation observés durant diverses périodes. Pour plus d'informations, consultez la rubrique Configurer et appliquer un plan d'ajustement planifié.

Resume mode

Vous pouvez sélectionner une stratégie de démarrage selon vos besoins métier et décider d'activer ou non Autopilot.

Stratégie	Description
Latest State	Reprend le déploiement à partir du dernier `savepoint` ou `checkpoint` disponible. Si vous sélectionnez cette option pour un déploiement SQL, le système Flink détecte les modifications apportées au code SQL, aux paramètres d'exécution Flink et à la version du moteur. Si des modifications sont détectées, nous vous recommandons de cliquer sur Click to detect à côté de State Compatibility afin de vérifier la compatibilité. Procédez ensuite en fonction des résultats. Pour obtenir des informations sur les résultats de compatibilité et les actions suggérées, consultez la section Compatibility.
Specific State	Sélectionnez un savepoint spécifique à partir duquel reprendre. Pour savoir comment créer un savepoint, consultez la rubrique Gérer l'état du déploiement.
Autre état de déploiement	Après avoir sélectionné cette option, spécifiez un déploiement cible et son savepoint correspondant à partir duquel reprendre. Les savepoints peuvent être partagés entre les déploiements, mais l'état doit être compatible. Pour plus d'informations, consultez la rubrique Gérer l'état du déploiement.
Allow Non-restored State Remarque Cette option est prise en charge uniquement pour les déploiements JAR.	Par défaut, Flink tente de mapper l'intégralité du savepoint aux opérateurs du nouveau déploiement. Si des modifications apportées au déploiement entraînent des changements dans l'état des opérateurs, la reprise du déploiement peut échouer. Activez cette option pour permettre à Flink d'ignorer tout état qui ne peut pas être mappé et de poursuivre le démarrage. Pour plus d'informations, consultez la documentation Allow Non-Restored State.
Configure Autopilot	Activez cette option et sélectionnez un mode d'ajustement : Mode Autopilot : le système réduit automatiquement les ressources lorsque l'utilisation est faible et les augmente lorsque l'utilisation atteint un certain seuil. Pour plus d'informations, consultez la rubrique Activer et configurer Autopilot. Mode planifié : vous devez sélectionner une planification dans la liste déroulante. Une planification peut contenir plusieurs configurations de ressources pour différents moments. Vous pouvez configurer les ressources en fonction des modèles d'utilisation observés durant diverses périodes. Pour plus d'informations, consultez la rubrique Configurer et appliquer un plan d'ajustement planifié.

Cliquez sur Start.

Sur la page O&M > Deployments, consultez le statut du déploiement. Pour plus d'informations, consultez la rubrique Consulter le statut du déploiement.

Documents connexes

Une fois le déploiement démarré, si vous devez modifier ses paramètres d'exécution, consultez la rubrique Configurer les paramètres d'exécution. Certains paramètres prennent également en charge les mises à jour dynamiques, ce qui évite les interruptions de service liées à l'arrêt et au redémarrage des déploiements. Pour plus d'informations, consultez la rubrique Mise à l'échelle dynamique et mises à jour dynamiques des paramètres.
Une fois le déploiement démarré, si vous avez besoin de tracer ses données pour localiser des problèmes ou évaluer leur impact, consultez la rubrique Consulter la lignée des données.
Pour en savoir plus sur le backend d'état GeminiStateBackend de niveau entreprise et comparer ses performances avec celles de RocksDBStateBackend, consultez la rubrique Présentation du backend d'état de niveau entreprise.