Il servizio gestito da Amazon per Apache Flink era precedentemente noto come Analisi dei dati Amazon Kinesis per Apache Flink.
Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.
FlinkKafkaConsumer problema con stop with savepoint
Quando si utilizza la versione precedente FlinkKafkaConsumer , è possibile che l'applicazione rimanga bloccata STOPPING o UPDATINGSCALING, se sono abilitate le istantanee di sistema. Non è disponibile alcuna correzione pubblicata per questo problema
Se si utilizza l'opzione FlinkKafkaConsumer con le istantanee abilitate, esiste la possibilità che, quando il job Flink elabora una API richiesta di interruzione con punto di salvataggio, l'operazione FlinkKafkaConsumer possa fallire con un errore di runtime che riporta un. ClosedException In queste condizioni l'applicazione Flink si blocca e dà luogo a checkpoint non riusciti.
