Re: "Error while retrieving the leader gateway" when using Kubernetes HA

2023-01-31 Thread Anton Ippolitov via user
ou could maybe try and review the fix :) >>> >>> Gyula >>> >>> On Tue, Jan 31, 2023 at 8:36 AM Yang Wang >>> wrote: >>> >>>> I assume you are using the standalone mode. Right? >>>> >>>> For the native K8s mo

Re: "Error while retrieving the leader gateway" when using Kubernetes HA

2023-01-31 Thread Anton Ippolitov via user
; *akka.tcp://flink@JM_POD_IP:6123/user/rpc/dispatcher_1 >> *when HA enabled. >> >> >> Best, >> Yang >> >> Anton Ippolitov via user 于2023年1月31日周二 00:21写道: >> >>> This is actually what I'm already doing, I'm only setting high-availability:

Re: "Error while retrieving the leader gateway" when using Kubernetes HA

2023-01-30 Thread Anton Ippolitov via user
configs? I think that can only cause problems and > should not achieve anything :) > > Gyula > > On Fri, Jan 27, 2023 at 6:44 PM Anton Ippolitov via user < > user@flink.apache.org> wrote: > >> Hi everyone, >> >> I've been experimenting with Kubernete

"Error while retrieving the leader gateway" when using Kubernetes HA

2023-01-27 Thread Anton Ippolitov via user
Hi everyone, I've been experimenting with Kubernetes HA and the Kubernetes Operator and ran into the following issue which is happening regularly on TaskManagers with Flink 1.16: Error while retrieving the leader gateway. Retrying to connect to akka.tcp://flink@SERVICE-NAME-HERE.NAMESPACE-HERE:61

Getting S3 client metrics from the flink-s3-fs-presto library

2022-12-15 Thread Anton Ippolitov via user
Hi, We recently switched to the flink-s3-fs-presto library for checkpointing in Flink 1.16.0 and we would like to get client-side metrics from the Presto S3 client (request rate, throttling rate, etc). I can see that the upstream client from Presto 0.272 already comes with a metric collector (Pre