Re: Unable to make mapWithState work correctly

Hi Victor, from a quick look at your code, I think, you set up everything just fine (I'm not too familiar with Scala though) but the problem is probably somewhere else: As [1] states (a bit hidden maybe), checkpoints are only used to recover from failures, e.g. if you run your job on 2 task mana

Unable to make mapWithState work correctly

Hi, I am trying to write a simple streaming program to count values from a Kafka topic in a fault tolerant manner, like this : val config: Configuration = new Configuration() config.setString(ConfigConstants.STATE_BACKEND,