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 !!
