[ https://issues.apache.org/jira/browse/SPARK-7318?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14525052#comment-14525052 ]
Apache Spark commented on SPARK-7318: ------------------------------------- User 'andrewor14' has created a pull request for this issue: https://github.com/apache/spark/pull/5860 > DStream isn't cleaning closures correctly > ----------------------------------------- > > Key: SPARK-7318 > URL: https://issues.apache.org/jira/browse/SPARK-7318 > Project: Spark > Issue Type: Bug > Components: Spark Core, Streaming > Affects Versions: 1.0.0 > Reporter: Andrew Or > Assignee: Andrew Or > Priority: Critical > > {code} > def transform[U: ClassTag](transformFunc: RDD[T] => RDD[U]): DStream[U] = { > transform((r: RDD[T], t: Time) => > context.sparkContext.clean(transformFunc(r), false)) > } > {code} > This is cleaning an RDD instead! -- This message was sent by Atlassian JIRA (v6.3.4#6332) --------------------------------------------------------------------- To unsubscribe, e-mail: issues-unsubscr...@spark.apache.org For additional commands, e-mail: issues-h...@spark.apache.org