diff --git a/modules/databricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala b/modules/databricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala index ab1751ce2..26fc867e7 100644 --- a/modules/databricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala +++ b/modules/databricks-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/databricks/Databricks.scala @@ -193,8 +193,8 @@ object Databricks { } private def qualify(tableName: String): String = tgt.catalog match { - case Some(catalog) => s"${catalog}.${tgt.schema}.$tableName" - case None => s"${tgt.schema}.$tableName" + case Some(catalog) => s"`${catalog}`.`${tgt.schema}`.$tableName" + case None => s"`${tgt.schema}`.$tableName" } } Right(result)