diff --git a/pydoop/hdfs/core/bridged/hadoop.py b/pydoop/hdfs/core/bridged/hadoop.py
index <HASH>..<HASH> 100644
--- a/pydoop/hdfs/core/bridged/hadoop.py
+++ b/pydoop/hdfs/core/bridged/hadoop.py
@@ -246,7 +246,7 @@ class CoreHdfsFs(CoreFsApi):
             else:
                 boolean_overwrite = True
                 if not blocksize:
-                    blocksize = self._fs.getDefaultBlockSize(jpath)
+                    blocksize = self.get_default_block_size()
                 stream = self._fs.create(
                     jpath, boolean_overwrite, buff_size, replication, blocksize
                 )
defaultBlockSize in hadoop.open_file(..) is now obtained using hadoop.get_default_block_size() method