Return a dataframe?

airbnb · Feb 12, 2024 · c0e7967 · c0e7967
1 parent c676864
commit c0e7967
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/spark/src/main/scala/ai/chronon/spark/TableUtils.scala b/spark/src/main/scala/ai/chronon/spark/TableUtils.scala
@@ -341,7 +341,7 @@ case class TableUtils(sparkSession: SparkSession) {
           if (existingFunctions.nonEmpty) {
             logger.warn(
               s"The following function(s) already exist(s): ${existingFunctions.mkString(", ")}. Query may result in function redefinition.")
-            return null
+            return sparkSession.sql("SELECT NULL")
           }
         }
         throw e