Skip to content

Commit

Permalink
fix athena iceberg locations
Browse files Browse the repository at this point in the history
  • Loading branch information
sh-rp committed Apr 17, 2024
1 parent c8b3429 commit 6522f87
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion dlt/destinations/impl/athena/athena.py
Original file line number Diff line number Diff line change
Expand Up @@ -367,7 +367,7 @@ def _get_table_update_sql(
if is_iceberg:
sql.append(f"""CREATE TABLE {qualified_table_name}
({columns})
LOCATION '{location}'
LOCATION '{location.rstrip('/')}'
TBLPROPERTIES ('table_type'='ICEBERG', 'format'='parquet');""")
elif table_format == "jsonl":
sql.append(f"""CREATE EXTERNAL TABLE {qualified_table_name}
Expand Down

0 comments on commit 6522f87

Please sign in to comment.