Apache Flink est une plate-forme open source pour le traitement évolutif des données par lots et par flux. Flink prend en charge l'analyse par lots et par flux, dans un seul système. Les programmes analytiques peuvent être écrits dans des API concises et élégantes en Java et Scala.
J'utilise Scala sur Flink avec l'API DataSet.
Je souhaite re-partitionner mes données sur les nœuds. Spark a une fonction qui permet à l'utilisateur de re-partitionner les donn ...
Dans notre application de streaming, qui utilise Flink 1.55 et son API de table, j'ai besoin de détecter et de gérer les éléments tardifs. Je ne parviens pas à t ...
J'ai un travail Flink qui a un grand état dans un opérateur Map. Nous prenons savepoint qui a environ 80 Go de stockage sur AWS S3. Nous avons environ 100 parallélismes pour c ...
J'essaie de configurer flink et d'exécuter un cluster, bien que j'obtienne la sortie suivante qui semble que le cluster a démarré: Error: Could not find or ...
