La modification des attributs de reconnaissance de motifs dans une tâche Flink SQL rompt la compatibilité avec les données d'état existantes.
Fonctionnement
Realtime Compute for Apache Flink implémente la reconnaissance de motifs via la clause MATCH_RECOGNIZE, qui s'appuie en interne sur le traitement complexe d'événements (CEP). Le moteur CEP construit une machine à états finis à partir de la définition du motif et stocke les séquences d'événements en cours de traitement sous forme de données d'état, liées à la structure de cette machine.
Les données d'état CEP constituent un instantané de la machine à états en cours d'exécution et sont étroitement couplées au motif qui les a générées. Toute modification du motif entraîne une nouvelle structure de machine à états, rendant les données d'état existantes incompatibles. Par conséquent, Flink ne peut pas migrer l'état de l'opérateur CEP lors d'une modification du motif.
Attributs qui rompent la compatibilité de l'état
La modification de l'un des attributs suivants dans une instruction SQL de reconnaissance de motifs rend la tâche incompatible avec ses données d'état existantes :
| Attribut | Rôle dans la reconnaissance de motifs |
|---|---|
pattern |
Définit la séquence d'événements à détecter |
measures |
Définit les colonnes de sortie extraites d'une correspondance |
after |
Contrôle la position de départ de la prochaine correspondance |
PARTITION BY |
Partitionne le flux d'entrée pour une détection indépendante par clé |
ORDER BY |
Définit l'ordre d'évaluation des événements |