Re: Backpressure tuning/failure

2019-10-10 Thread Owen Rees-Hayward
; assign resources in the cluster, using for example CGroups via > yarn/lxc/docker, or virtual machines. > > Cheers, Piotrek > > On 10 Oct 2019, at 16:02, Owen Rees-Hayward wrote: > > Hi Piotr, > > Thanks for getting back to me and for the info. I try to describe the > m

Re: Backpressure tuning/failure

2019-10-10 Thread Owen Rees-Hayward
e > could distribute records not randomly but to the less busy machines). > However this is a pretty much niche feature (failing machine + non keyed > exchanges) and you are not saying anywhere that this is what you are > testing for. > > Piotrek > > On 8 Oct 2019, at 18:

Backpressure tuning/failure

2019-10-08 Thread Owen Rees-Hayward
will publish in a day or two, and don't want to criticise the Flink backpressure implementation for what seems most likely some default configuration issue. Thanks in advance, Owen -- Owen Rees-Hayward 07912 876046 twitter.com/owen4d