Re: The JobManager is taking minutes to complete and finalize checkpoints despite the Task Managers seem to complete them in a few seconds

Hi Francesco, The overall checkpoint duration in Flink UI is EndToEndDuration[1], which is the time from Jobmanager triggering checkpoint to collecting the last ack message sent from task manager, depending on the slowest task manager. > "-_message__:__"Completed checkpoint 2515895 for job > fdc

Re: Query on class annotation like @Experimental

Thanks for the clarification. On Wed, May 3, 2023 at 1:16 PM Yangze Guo wrote: > Hi, Anuj, > > - Classes annotated with @Internal are not public API and thus might > change across any two releases. > - Classes annotated with @Experimental are for experimental use. They > can be changed across an

Re: Query on class annotation like @Experimental

Hi, Anuj, - Classes annotated with @Internal are not public API and thus might change across any two releases. - Classes annotated with @Experimental are for experimental use. They can be changed across any two releases as well. - Classes annotated with @PublicEvolving are intended for public use.