If you can do it in this pr that would be great!

On Wednesday, April 16, 2014, Shixiong Zhu <notifications@github.com> wrote:

> In
> streaming/src/main/scala/org/apache/spark/streaming/dstream/DStream.scala:
>
> > @@ -725,6 +725,9 @@ abstract class DStream[T: ClassTag] (
> >     * Return all the RDDs between 'fromTime' to 'toTime' (both included)
> >     */
> >    def slice(fromTime: Time, toTime: Time): Seq[RDD[T]] = {
> > +    if (!isInitialized) {
> > +      throw new Exception(this + " has not been initialized")
>
> Sure. One more question: There are many new Exception in DStream.scala.
> It's necessary to change them to SparkExcepation?
>
> --
> Reply to this email directly or view it on GitHub<https://github.com/apache/spark/pull/365/files#r11716967>
> .
>