diff --git a/cloud/src/recycler/hdfs_accessor.cpp b/cloud/src/recycler/hdfs_accessor.cpp
index 1999bcfa16543a..024acd0efe7852 100644
--- a/cloud/src/recycler/hdfs_accessor.cpp
+++ b/cloud/src/recycler/hdfs_accessor.cpp
@@ -356,6 +356,7 @@ std::string extract_parent_path(const std::string& path) {
 }
 
 int HdfsAccessor::init() {
+    TEST_SYNC_POINT_RETURN_WITH_VALUE("HdfsAccessor::init.hdfs_init_failed", (int)-1);
     // TODO(plat1ko): Cache hdfsFS
     fs_ = HDFSBuilder::create_fs(info_.build_conf());
     if (!fs_) {
diff --git a/cloud/test/recycler_test.cpp b/cloud/test/recycler_test.cpp
index 567d27f5d6f3c4..42ab8f629cb643 100644
--- a/cloud/test/recycler_test.cpp
+++ b/cloud/test/recycler_test.cpp
@@ -3352,6 +3352,12 @@ TEST(RecyclerTest, init_vault_accessor_failed_test) {
         rs = resp->add_rowset_meta();
         rs->set_resource_id("success_vault");
     });
+    sp->set_call_back("HdfsAccessor::init.hdfs_init_failed", [](auto&& args) {
+        auto* ret = try_any_cast_ret<int>(args);
+        ret->first = -1;
+        ret->second = true;
+    });
+
     sp->enable_processing();
 
     // succeed to init MockAccessor
@@ -3371,7 +3377,6 @@ TEST(RecyclerTest, init_vault_accessor_failed_test) {
         instance.set_instance_id("GetObjStoreInfoTestInstance");
         txn->put(storage_vault_key({instance.instance_id(), "4"}), vault.SerializeAsString());
     }
-
     val = instance.SerializeAsString();
     txn->put(key, val);
     EXPECT_EQ(txn->commit(), TxnErrorCode::TXN_OK);