diff --git a/writeengine/redistribute/we_redistributeworkerthread.cpp b/writeengine/redistribute/we_redistributeworkerthread.cpp index c16a0a82e..b2ed7ba47 100644 --- a/writeengine/redistribute/we_redistributeworkerthread.cpp +++ b/writeengine/redistribute/we_redistributeworkerthread.cpp @@ -1050,8 +1050,11 @@ void RedistributeWorkerThread::confirmToPeer() } } - IDBFileSystem& fs = IDBFileSystem::getFs( - (IDBPolicy::useHdfs() ? IDBDataFile::HDFS : IDBDataFile::UNBUFFERED) ); + IDBFileSystem& fs = (IDBPolicy::useHdfs() ? + IDBFileSystem::getFs(IDBDataFile::HDFS) : + IDBPolicy::useCloud() ? + IDBFileSystem::getFs(IDBDataFile::CLOUD) : + IDBFileSystem::getFs(IDBDataFile::BUFFERED)); uint32_t confirmCode = RED_DATA_COMMIT;