File tree 1 file changed +1
-2
lines changed
spark/src/main/scala/ai/chronon/spark
1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -38,7 +38,6 @@ import org.apache.spark.sql.SaveMode
38
38
import org .apache .spark .sql .SparkSession
39
39
import org .apache .spark .sql .catalyst .analysis .TableAlreadyExistsException
40
40
import org .apache .spark .sql .catalyst .analysis .UnresolvedRelation
41
- import org .apache .spark .sql .catalyst .parser .CatalystSqlParser
42
41
import org .apache .spark .sql .catalyst .plans .logical .Filter
43
42
import org .apache .spark .sql .catalyst .plans .logical .LogicalPlan
44
43
import org .apache .spark .sql .catalyst .plans .logical .Project
@@ -431,7 +430,7 @@ class TableUtils(@transient val sparkSession: SparkSession) extends Serializable
431
430
.getOrElse(throw new IllegalArgumentException (" Could not find candidate dataset for materializationDataset" ))
432
431
val originalViewsEnabled = sparkSession.conf.get(" viewsEnabled" , false .toString)
433
432
val originalMaterializationDataset = sparkSession.conf.get(" materializationDataset" , " " )
434
- sparkSession.conf.set(" viewsEnabled" , " true" )
433
+ sparkSession.conf.set(" viewsEnabled" , true .toString )
435
434
sparkSession.conf.set(" materializationDataset" , firstDataset)
436
435
val df = sparkSession.read.format(" bigquery" ).load(query)
437
436
sparkSession.conf.set(" viewsEnabled" , originalViewsEnabled)
You can’t perform that action at this time.
0 commit comments