From a343d8af9c577158042e4af9f8832f46aeecd509 Mon Sep 17 00:00:00 2001 From: Kunal Khamar Date: Mon, 6 Feb 2017 15:24:02 -0800 Subject: [PATCH] Fix constructor default args for bytecode compatibility. --- .../main/scala/org/apache/spark/sql/SparkSession.scala | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala index 00142c3151e54..0db2bfbd56280 100644 --- a/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala +++ b/sql/core/src/main/scala/org/apache/spark/sql/SparkSession.scala @@ -73,11 +73,15 @@ import org.apache.spark.util.Utils class SparkSession private( @transient val sparkContext: SparkContext, @transient private val existingSharedState: Option[SharedState], - existingSessionState: Option[SessionState] = None) + existingSessionState: Option[SessionState]) extends Serializable with Closeable with Logging { self => + private[sql] def this(sc: SparkContext, existingSharedState: Option[SharedState]) { + this(sc, existingSharedState, None) + } + private[sql] def this(sc: SparkContext) { - this(sc, None) + this(sc, None, None) } sparkContext.assertNotStopped()