Skip to content

Commit 15b281a

Browse files
Yuri Nikonchukclaude
authored andcommitted
Default hdfs.replication to 0 (defer to hdfs-site.xml)
Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
1 parent 3da3cce commit 15b281a

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

pyiceberg/io/pyarrow.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -579,8 +579,8 @@ def _initialize_hdfs_fs(self, scheme: str, netloc: Optional[str]) -> FileSystem:
579579
from pyarrow.fs import HadoopFileSystem
580580

581581
hdfs_kwargs: Dict[str, Any] = {}
582-
if replication := self.properties.get(HDFS_REPLICATION):
583-
hdfs_kwargs["replication"] = int(replication)
582+
replication = self.properties.get(HDFS_REPLICATION, "0")
583+
hdfs_kwargs["replication"] = int(replication)
584584
if netloc:
585585
hdfs_kwargs["host"] = netloc
586586
elif host := self.properties.get(HDFS_HOST):

0 commit comments

Comments
 (0)