Fix create external table statement for delta tables

metabolicdata · Jan 31, 2024 · 260ebaf · 260ebaf
1 parent 549df77
commit 260ebaf
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/com/metabolic/data/core/services/glue/AthenaCatalogueService.scala b/src/main/scala/com/metabolic/data/core/services/glue/AthenaCatalogueService.scala
@@ -20,7 +20,7 @@ class AthenaCatalogueService(implicit val region: Regions) extends Logging {
   private def createTableStatement(dbName: String, tableName: String, s3_location: String) = {
 
     s"CREATE EXTERNAL TABLE IF NOT EXISTS " +
-      s"$dbName.$tableName" +
+      s"`$dbName`.`$tableName`" +
       s" LOCATION '$s3_location'" +
       "TBLPROPERTIES ('table_type' = 'DELTA')"