Re: Flink k8 HA mode + checkpoint management

2021-08-05 Thread Yang Wang
/apache/flink/runtime/checkpoint/CheckpointCoordinator.java#L1226 > > > Best > Yun Tang > -- > *From:* Manong Karl > *Sent:* Wednesday, August 4, 2021 9:17 > *To:* Harsh Shah > *Cc:* user@flink.apache.org > *Subject:* Re: Flink k8 HA mode + checkpoint management &

Re: Flink k8 HA mode + checkpoint management

2021-08-03 Thread Yun Tang
/CheckpointCoordinator.java#L1226 Best Yun Tang From: Manong Karl Sent: Wednesday, August 4, 2021 9:17 To: Harsh Shah Cc: user@flink.apache.org Subject: Re: Flink k8 HA mode + checkpoint management Can You please share your configs? I'm using native kubernetes without HA

Re: Flink k8 HA mode + checkpoint management

2021-08-03 Thread Manong Karl
Can You please share your configs? I'm using native kubernetes without HA and there's no issues. I'm curious how this happens. AFAIK jobid is generated randomly. Harsh Shah 于2021年8月4日周三 上午2:44写道： > Hello, > > I am trying to use Flink HA mode inside kubernetes >

Flink k8 HA mode + checkpoint management

2021-08-03 Thread Harsh Shah
Hello, I am trying to use Flink HA mode inside kubernetes in standalone