We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent f92c294 commit 20e8555Copy full SHA for 20e8555
sql/core/src/main/scala/org/apache/spark/sql/execution/SparkSqlSerializer.scala
@@ -49,7 +49,7 @@ private[sql] class SparkSqlSerializer(conf: SparkConf) extends KryoSerializer(co
49
}
50
51
private[execution] class KryoResourcePool(size: Int)
52
- extends ResourcePool[SerializerInstance](size) {
+ extends ResourcePool[SerializerInstance](size) {
53
54
val ser: KryoSerializer = {
55
val sparkConf = Option(SparkEnv.get).map(_.conf).getOrElse(new SparkConf())
@@ -59,8 +59,7 @@ private[execution] class KryoResourcePool(size: Int)
59
new KryoSerializer(sparkConf)
60
61
62
- def newInstance() =
63
- ser.newInstance()
+ def newInstance() = ser.newInstance()
64
65
66
private[sql] object SparkSqlSerializer {
0 commit comments