Snowflake Loader: fix folder monitoring copy statement (close #851)

snowplow · Apr 28, 2022 · 1b54654 · 1b54654
1 parent cf9bc8e
commit 1b54654
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ake-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/snowflake/Snowflake.scala b/...ake-loader/src/main/scala/com/snowplowanalytics/snowplow/loader/snowflake/Snowflake.scala
@@ -98,7 +98,7 @@ object Snowflake {
                 // This is validated on config decoding stage
                 val stageName = monitoringStage.getOrElse(throw new IllegalStateException("Folder Monitoring is launched without monitoring stage being provided"))
                 val frPath      = Fragment.const0(s"@$schema.$stageName/${source.folderName}")
-                sql"~ INTO $frTableName FROM $frPath FILE_FORMAT = (TYPE = CSV)"
+                sql"COPY INTO $frTableName FROM $frPath FILE_FORMAT = (TYPE = CSV)"
 
               case Statement.EventsCopy(path, _) =>
                 val frTableName = Fragment.const(EventsTable.MainName)