ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Declare Vids explicitly to avoid ClassCastException

Browse source
This commit is contained in:
Ankur Dave 2013-12-04 17:34:14 -08:00
parent 92e96f727e
commit 2e583d2de4
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
graph/src/test/scala/org/apache/spark/graph/SerializerSuite.scala
View file

@ -79,7 +79,7 @@ class SerializerSuite extends FunSuite with LocalSparkContext {
} }
test("IntAggMsgSerializer") { test("IntAggMsgSerializer") {
val outMsg = (4, 5) val outMsg = (4: Vid, 5)
val bout = new ByteArrayOutputStream val bout = new ByteArrayOutputStream
val outStrm = new IntAggMsgSerializer().newInstance().serializeStream(bout) val outStrm = new IntAggMsgSerializer().newInstance().serializeStream(bout)
outStrm.writeObject(outMsg) outStrm.writeObject(outMsg)
@ -98,7 +98,7 @@ class SerializerSuite extends FunSuite with LocalSparkContext {
} }
test("LongAggMsgSerializer") { test("LongAggMsgSerializer") {
val outMsg = (4, 1L << 32) val outMsg = (4: Vid, 1L << 32)
val bout = new ByteArrayOutputStream val bout = new ByteArrayOutputStream
val outStrm = new LongAggMsgSerializer().newInstance().serializeStream(bout) val outStrm = new LongAggMsgSerializer().newInstance().serializeStream(bout)
outStrm.writeObject(outMsg) outStrm.writeObject(outMsg)
@ -117,7 +117,7 @@ class SerializerSuite extends FunSuite with LocalSparkContext {
} }
test("DoubleAggMsgSerializer") { test("DoubleAggMsgSerializer") {
val outMsg = (4, 5.0) val outMsg = (4: Vid, 5.0)
val bout = new ByteArrayOutputStream val bout = new ByteArrayOutputStream
val outStrm = new DoubleAggMsgSerializer().newInstance().serializeStream(bout) val outStrm = new DoubleAggMsgSerializer().newInstance().serializeStream(bout)
outStrm.writeObject(outMsg) outStrm.writeObject(outMsg)