Re: Change in accumutors semantics with jobClient

2021-06-24 Thread Etienne Chauchot
My pleasure ! Thanks for pointing out the release notes. Cheers, Etienne On 23/06/2021 14:00, Till Rohrmann wrote: Yes, it should be part of the release notes where this change was introduced. I'll take a look at your PR. Thanks a lot Etienne. Cheers, Till On Wed, Jun 23, 2021 at 12:29 PM

Re: Change in accumutors semantics with jobClient

2021-06-23 Thread Till Rohrmann
Yes, it should be part of the release notes where this change was introduced. I'll take a look at your PR. Thanks a lot Etienne. Cheers, Till On Wed, Jun 23, 2021 at 12:29 PM Etienne Chauchot wrote: > Hi Till, > > Of course I can update the release notes. > > Question is: this change is quite

Re: Change in accumutors semantics with jobClient

2021-06-23 Thread Etienne Chauchot
Hi Till, Of course I can update the release notes. Question is: this change is quite old (January), it is already available in all the maintained releases :1.11, 1.12, 1.13. I think I should update the release notes for all these versions no ? In case you agree, I took the liberty to update

Re: Change in accumutors semantics with jobClient

2021-06-21 Thread Till Rohrmann
Thanks for bringing this to the dev ML Etienne. Could you maybe update the release notes for Flink 1.13 [1] to include this change? That way it might be a bit more prominent. I think the change needs to go into the release-1.13 and master branch. [1]

Change in accumutors semantics with jobClient

2021-06-18 Thread Etienne Chauchot
Hi all, I did a fix some time ago regarding accumulators: the/JobClient.getAccumulators()/ was infinitely  blocking in local environment for a streaming job (1). The change (2) consisted of giving the current accumulators value for the running job. And when fixing this in the PR, it appeared