File tree Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Expand file tree Collapse file tree 2 files changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -968,8 +968,12 @@ void SsdFile::readCheckpoint() {
968
968
memory::memoryManager ()->cachePool ());
969
969
} catch (std::exception& e) {
970
970
++stats_.openCheckpointErrors ;
971
- VELOX_SSD_CACHE_LOG (WARNING)
972
- << fmt::format (" Error openning checkpoint file {}: " , e.what ());
971
+ // Either the checkpoint file is corrupted or the file is just created, we
972
+ // can start here and the writer threads will create the checkpoint file
973
+ // later on flush
974
+ VELOX_SSD_CACHE_LOG (WARNING) << fmt::format (
975
+ " Error opening checkpoint file {}: Starting without checkpoint" ,
976
+ e.what ());
973
977
return ;
974
978
}
975
979
Original file line number Diff line number Diff line change @@ -66,7 +66,7 @@ DEFINE_int32(
66
66
-1 ,
67
67
" Number of SSD cache shards. When set to -1, a random value from 1 to 4 will be used, inclusively." );
68
68
69
- DEFINE_bool (ssd_odirect, true , " Use O_DIRECT for SSD cache IO " );
69
+ DECLARE_bool (velox_ssd_odirect );
70
70
71
71
DEFINE_int64 (
72
72
ssd_checkpoint_interval_bytes,
@@ -505,7 +505,7 @@ void CacheFuzzer::go() {
505
505
// filesystem and kernel version.
506
506
//
507
507
// TODO: add this support if needed later.
508
- FLAGS_ssd_odirect = false ;
508
+ FLAGS_velox_ssd_odirect = false ;
509
509
auto startTime = std::chrono::system_clock::now ();
510
510
size_t iteration = 0 ;
511
511
You can’t perform that action at this time.
0 commit comments