Sure. One more question: There are many `new Exception` in DStream.scala. It's necessary to change them to `SparkExcepation`?