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.getA
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 ythu...@winbond.com wrote:
Hi All,
I have a problem with broadcasting a serialize
