AnsweredAssumed Answered

Restore Spark Streaming with MapR Streams

Question asked by daaa on Jun 9, 2017
Latest reply on Dec 6, 2017 by john.humphreys
Branched to a new discussion
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 partitions
ERROR StreamListener fs/client/marlin/cc/listener/jni_listener.cc:627 Thread: 108325 Seek failed with err:2
 
Any help is appreciated.

Outcomes