We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3249b97 commit 6541206Copy full SHA for 6541206
sdk/python/feast/infra/offline_stores/file.py
@@ -453,7 +453,9 @@ def offline_write_batch(
453
filesystem, path = FileSource.create_filesystem_and_path(
454
file_options.uri, file_options.s3_endpoint_override
455
)
456
- prev_table = pyarrow.parquet.read_table(path, memory_map=True)
+ prev_table = pyarrow.parquet.read_table(
457
+ path, filesystem=filesystem, memory_map=True
458
+ )
459
if table.schema != prev_table.schema:
460
table = table.cast(prev_table.schema)
461
new_table = pyarrow.concat_tables([table, prev_table])
0 commit comments