Github user srowen commented on a diff in the pull request:
https://github.com/apache/spark/pull/19950#discussion_r157343175
--- Diff:
mllib/src/test/scala/org/apache/spark/mllib/clustering/KMeansSuite.scala ---
@@ -311,6 +312,23 @@ class KMeansSuite extends SparkFunSuite with
MLlibTestSparkContext {
assert(returnModel.clusterCenters(1) ===
initialModel.clusterCenters(1))
}
+ test("Kryo class register") {
+ val conf = new SparkConf(false)
+ conf.set("spark.kryo.registrationRequired", "true")
+
+ val ser = new KryoSerializer(conf).newInstance()
+
+ def check(v: VectorWithNorm): Unit = {
--- End diff --
Likewise these seem like things you can just write in a loop over several
objects to test
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
