Hi Ted,
Yeah, I saw the line, but forgot it's a test that may have been
testing that closures should not have return. More clear now. Thanks!
Pozdrawiam,
Jacek Laskowski
https://medium.com/@jaceklaskowski/
Mastering Apache Spark http://bit.ly/mastering-apache-spark
Follow me at
The next line should give some clue:
expectCorrectException { ssc.transform(Seq(ds), transformF) }
Closure shouldn't include return.
On Tue, Apr 5, 2016 at 3:40 PM, Jacek Laskowski wrote:
> Hi,
>
> In
>
Hi,
In
https://github.com/apache/spark/blob/master/streaming/src/test/scala/org/apache/spark/streaming/DStreamClosureSuite.scala#L190:
{ return; ssc.sparkContext.emptyRDD[Int] }
What is this return inside for? I don't understand the line and am
about to propose a change to remove it.