For properties not exposed through Beam's FlinkPipelineOptions, Flink's usual configuration management (usually conf/flink-conf.yaml) applies. You should be able to set the checkpoint directory via state.checkpoints.dir per https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/checkpoints.html. Let us know if that doesn't work.
On Wed, Jul 8, 2020 at 9:56 PM akul sharma <[email protected]> wrote: > I am executing a word count streaming job using kafka producer as an > unbound input source and kafka consumers to write output. > Till this everything worked fine. But when i tried for checkpointing by > enabling setCheckpoingInterval parameter of flinkPipelineOptions interface, > i am unable to see the checkpoint directories . > > Can anyone tell me where to specify the path for checkpoint directory or > how to set checkpointConfig while performing a streaming job !! > >
