File tree Expand file tree Collapse file tree 2 files changed +30
-0
lines changed
Expand file tree Collapse file tree 2 files changed +30
-0
lines changed Original file line number Diff line number Diff line change 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+ )
Original file line number Diff line number Diff 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 ()
You can’t perform that action at this time.
0 commit comments