Skip to content

Commit 0ecf487

Browse files
committed
fix athena iceberg locations
1 parent ca3e95f commit 0ecf487

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

dlt/destinations/impl/athena/athena.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -367,7 +367,7 @@ def _get_table_update_sql(
367367
if is_iceberg:
368368
sql.append(f"""CREATE TABLE {qualified_table_name}
369369
({columns})
370-
LOCATION '{location}'
370+
LOCATION '{location.rstrip('/')}'
371371
TBLPROPERTIES ('table_type'='ICEBERG', 'format'='parquet');""")
372372
elif table_format == "jsonl":
373373
sql.append(f"""CREATE EXTERNAL TABLE {qualified_table_name}

0 commit comments

Comments
 (0)