diff --git a/target_duckdb/db_sync.py b/target_duckdb/db_sync.py
index 2c826e7..50b4a32 100644
--- a/target_duckdb/db_sync.py
+++ b/target_duckdb/db_sync.py
@@ -384,7 +384,7 @@ def load_rows(self, records, count, temp_dir):
             )
             for record in records:
                 csvwriter.writerow(self.record_to_flattened(record))
-        cur.execute("COPY {} FROM '{}'".format(temp_table, temp_file_csv))
+        cur.execute("COPY {} FROM '{}' WITH (new_line '\\r\\n')".format(temp_table, temp_file_csv))
 
         if len(self.stream_schema_message["key_properties"]) > 0:
             cur.execute(self.update_from_temp_table(temp_table))