diff --git a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala index 471481659116e07bea7492bc51c7200198d85747..ba8ba10141f933d3e3607d3d10e5ec1b87c7aa6e 100644 --- a/core/src/main/scala/spark/broadcast/HttpBroadcast.scala +++ b/core/src/main/scala/spark/broadcast/HttpBroadcast.scala @@ -106,5 +106,6 @@ private object HttpBroadcast extends Logging { val serIn = ser.inputStream(in) val obj = serIn.readObject() serIn.close() + obj } }