Hi,

I'm using Flink 1.14 and was unable to set S3 as state backend. I tried
combination of:

SET state.backend='filesystem';
SET state.checkpoints.dir='s3://xxx/checkpoints/';
SET state.backend.fs.checkpointdir='s3://xxx/checkpoints/';
SET state.checkpoint-storage='filesystem'

As well as:

SET state.backend='hashmap';

Which covered both legacy 1.13 way to do it and 1.14 new way to do it.

None worked. In the Web UI I see checkpoints being made to the Job Manager
continuously. Configuration reads:

- Checkpoint Storage: JobManagerCheckpointStorage
- State Backend: HashMapStateBackend

Is this a bug? Is there a way to set state backend to S3 using SQL Client?

Thanks,
Dai

Reply via email to