Hi, Shrihari.
It seems related to https://issues.apache.org/jira/browse/FLINK-28758 which
is unresolved now.
It should only occur in FlinkKafkaConsumer, So you could migrate to
KafkaSource to avoid this issue.
On Sat, Jun 24, 2023 at 2:46 AM Shrihari R wrote:
> I am trying to stop the job by t
I am trying to stop the job by triggering the savepoint, but it's
failing with the below error.
*./bin/flink stop --savepointPath
gs://staging-data-flink/flink-1-16-2/savepoints/
3a912091b13c446c0d359074414db1db*
it's working if I just trigger the save point without stopping the job.
*./bin/flink
On Fri, Jun 23, 2023 at 11:54 PM Shrihari R wrote:
> Hi All,
>
> I am trying to stop the job by triggering the savepoint, but it's
> failing with the below attached error.
>
> *Command Used*
> ./bin/flink stop --savepointPath
> gs://staging-data-flink/flink-1-16-2/savepoints/
> 3a912091b13c446c0d
