Exécuter des applications

Voyez comment exécuter les applications que vous avez créées dans le service de flux de données, fournir des valeurs d'argument et de paramètre, vérifier les résultats et diagnostiquer et ajuster les exécutions, y compris les options JVM.

Important

Le service de flux de données arrête automatiquement les tâches par lots de longue durée à l'aide de jetons de délégation après 24 heures et les tâches par lots de longue durée à l'aide de principaux de ressources après 30 jours. Aucun avis n'est donné indiquant que le travail est sur le point d'être arrêté.
Si l'application n'a pas terminé le traitement des données, il se peut que l'exécution échoue et que le travail reste inachevé. Pour éviter cela, utilisez les options suivantes pour limiter le temps total d'exécution de l'application :
Lors de la création d'exécutions à l'aide de la console
Sous Options avancées, spécifiez la durée en durée maximale d'exécution en minutes.
Lors de la création d'exécutions à l'aide de l'interface de ligne de commande
Transmettre l'option de ligne de commande de --max-duration-in-minutes <number>
Lors de la création d'exécutions à l'aide de la trousse SDK
Indiquez un argument facultatif max_duration_in_minutes
Lors de la création d'exécutions à l'aide de l'API
Définir l'argument facultatif maxDurationInMinutes

Présentation des exécutions

Chaque fois qu'une application de flux de données est répartie, une exécution de flux de données est créée. L'exécution du flux de données saisit et stocke de manière sécurisée la sortie, les journaux et les statistiques de l'application. La sortie est enregistrée afin qu'elle puisse être vue par toute personne ayant les autorisations appropriées au moyen de l'interface utilisateur ou de l'API REST. Les exécutions procurent également un accès sécurisé à l'interface Spark  pour le débogage et les diagnostics.