assert msg

juliuszsompolski · juliuszsompolski · commit 1ecb766a42ba · 2018-01-02T16:55:42.000+01:00
diff --git a/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala b/sql/catalyst/src/main/scala/org/apache/spark/sql/internal/SQLConf.scala
@@ -1091,7 +1091,8 @@ class SQLConf extends Serializable with Logging {
 
   if (Utils.isTesting && SparkEnv.get != null) {
     // assert that we're only accessing it on the driver.
-    assert(SparkEnv.get.executorId == SparkContext.DRIVER_IDENTIFIER)
+    assert(SparkEnv.get.executorId == SparkContext.DRIVER_IDENTIFIER,
+      "SQLConf should only be created and accessed on the driver.")
   }
 
   /** Only low degree of contention is expected for conf, thus NOT using ConcurrentHashMap. */

Original file line number	Diff line number	Diff line change
`@@ -1091,7 +1091,8 @@ class SQLConf extends Serializable with Logging {`
`1091`	`1091`
`1092`	`1092`	`if (Utils.isTesting && SparkEnv.get != null) {`
`1093`	`1093`	`// assert that we're only accessing it on the driver.`
`1094`		`- assert(SparkEnv.get.executorId == SparkContext.DRIVER_IDENTIFIER)`
	`1094`	`+ assert(SparkEnv.get.executorId == SparkContext.DRIVER_IDENTIFIER,`
	`1095`	`+ "SQLConf should only be created and accessed on the driver.")`
`1095`	`1096`	`}`
`1096`	`1097`
`1097`	`1098`	`/** Only low degree of contention is expected for conf, thus NOT using ConcurrentHashMap. */`