I'm using spark streaming and use updateStateByKey, which forced to use checkpoint. In my unit test, I create a queueStream to test. But in spark 1.5, QueueStream will throw an exception while use it with checkpoint, it makes difficult to do unit test. Is there an option to disable this? Though I know it will fail to recover from checkpoint but since it is a test I don't care it.
I've found the git commit here https://mail-archives.apache.org/mod_mbox/incubator-spark-commits/201506.mbox/%3c8efccd27016447fb8d1e0b3d9582b...@git.apache.org%3E
