Hi Team,
We have recently enabled Check Pointing in our flink job using
FSStateBackend pointing to S3 bucket.
Below is the sample code for enabling check pointing though app code and we
are using flink version - 1.12.2 .
env.setStateBackend(new
FsStateBackend("s3://flinkcheckpointing/job-name/",
Hi Sudhansu,
I think you do not need to set the config in flink-conf.
Best,
Guowei
On Thu, May 13, 2021 at 1:06 PM sudhansu jena
wrote:
> Hi Team,
>
> We have recently enabled Check Pointing in our flink job using
> FSStateBackend pointing to S3 bucket.
>
> Below is the sample code for enabling