Hi,
Just ran your code on spark-shell. If you replace
val bcA = sc.broadcast(a)
with
val bcA = sc.broadcast(new B().getA)
it seems to work. Not sure why.
On Tue, Dec 23, 2014 at 9:12 AM, Henry Hung wrote:
> Hi All,
>
>
>
> I have a problem with broadcasting a serialize class object th
Hi All,
I have a problem with broadcasting a serialize class object that returned by
another not-serialize class, here is the sample code:
class A extends java.io.Serializable {
def halo(): String = "halo"
}
class B {
def getA() = new A
}
val list = List(1)
val b = new B
val a = b.get