Hadoop: Set the local osd to be the preferred osd for all writes.

diff --git a/src/client/hadoop/CephFSInterface.cc b/src/client/hadoop/CephFSInterface.cc
index 786d1cb905f72a37d2d0e6294f63aa21467a10a5..a5629c63dfe52abbfac15ccc0f5fc9181a5c28e7 100644 (file)
--- a/src/client/hadoop/CephFSInterface.cc
+++ b/src/client/hadoop/CephFSInterface.cc
@@ -56,6 +56,7 @@ JNIEXPORT jboolean JNICALL Java_org_apache_hadoop_fs_ceph_CephFileSystem_ceph_1i
 
   ceph_set_default_file_stripe_unit(block_size);
   ceph_set_default_object_size(block_size);
+  ceph_set_default_preferred_pg(ceph_get_local_osd());
 
   if (r < 0) return false;
   r = ceph_mount();