Skip to content

Commit 6808149

Browse files
committed
issue
1 parent affcbd1 commit 6808149

File tree

2 files changed

+30
-0
lines changed

2 files changed

+30
-0
lines changed

dev/provision.py

Lines changed: 20 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -301,3 +301,23 @@
301301
);
302302
"""
303303
)
304+
305+
spark.sql(
306+
"""
307+
CREATE TABLE default.test_table_sanitized_character (
308+
`letter/abc` string
309+
)
310+
USING iceberg
311+
TBLPROPERTIES (
312+
'format-version'='1'
313+
);
314+
"""
315+
)
316+
317+
spark.sql(
318+
f"""
319+
INSERT INTO default.test_table_sanitized_character
320+
VALUES
321+
('123')
322+
"""
323+
)

tests/test_integration.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -396,3 +396,13 @@ def test_upgrade_table_version(table_test_table_version: Table) -> None:
396396
with table_test_table_version.transaction() as transaction:
397397
transaction.upgrade_table_version(format_version=3)
398398
assert "Unsupported table format version: 3" in str(e.value)
399+
400+
401+
@pytest.fixture()
402+
def table_test_table_sanitized_character(catalog: Catalog) -> Table:
403+
return catalog.load_table("default.test_table_sanitized_character")
404+
405+
406+
@pytest.mark.integration
407+
def test_reproduce_issue(table_test_table_sanitized_character: Table) -> None:
408+
table = table_test_table_sanitized_character.scan().to_arrow()

0 commit comments

Comments
 (0)