Spark streaming fournit une API pour la terminaison awaitTermination(). Existe-t-il une API similaire disponible pour arrêter gracieusement la diffusion de flink après quelques secondes?Flink streaming: comment contrôler le temps d'exécution
Votre programme pilote (c'est-à-dire la méthode main) dans Flink ne reste pas actif pendant l'exécution du travail de diffusion. Votre programme doit définir un flux de données, appelez execute, puis terminez. Dans Spark, le programme du pilote reste en cours d'exécution (AFAIK) et awaitTermination se rapporte à cela.
Notez qu'un flux de données en continu Flink continue à s'exécuter indéfiniment, sauf si vous utilisez une source de données 'délimitée' avec un nombre fini d'éléments. Vous pouvez également annuler ou arrêter un travail, et même prendre un point de contrôle à l'arrêt pour reprendre à partir de plus tard.