I am trying to use Spark Streaming with MapR Streams.
Streaming application is enable checkoonting.
I can execute Streaming application,but not restore from checkpoint with following exception.
org.apache.kafka.common.errors.UnknownTopicOrPartitionException :No such file or directory (2) Could not seek.
And I found the following ERROR.
ERROR StreamListener fs/client/marlin/cc/listener/listenerimpl.cc:760 Thread: 108325 Seek called on unsubscribed partitionsERROR StreamListener fs/client/marlin/cc/listener/jni_listener.cc:627 Thread: 108325 Seek failed with err:2
Any help is appreciated.