|
|
@ -306,8 +306,16 @@ Status ExternalSstFileIngestionJob::GetIngestedFileInfo( |
|
|
|
if (file_to_ingest->global_seqno_offset == 0) { |
|
|
|
if (file_to_ingest->global_seqno_offset == 0) { |
|
|
|
return Status::Corruption("Was not able to find file global seqno field"); |
|
|
|
return Status::Corruption("Was not able to find file global seqno field"); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
} else if (file_to_ingest->version == 1) { |
|
|
|
|
|
|
|
// SST file V1 should not have global seqno field
|
|
|
|
|
|
|
|
assert(seqno_iter == uprops.end()); |
|
|
|
|
|
|
|
if (ingestion_options_.allow_blocking_flush || |
|
|
|
|
|
|
|
ingestion_options_.allow_global_seqno) { |
|
|
|
|
|
|
|
return Status::InvalidArgument( |
|
|
|
|
|
|
|
"External SST file V1 does not support global seqno"); |
|
|
|
|
|
|
|
} |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
return Status::InvalidArgument("external file version is not supported"); |
|
|
|
return Status::InvalidArgument("External file version is not supported"); |
|
|
|
} |
|
|
|
} |
|
|
|
// Get number of entries in table
|
|
|
|
// Get number of entries in table
|
|
|
|
file_to_ingest->num_entries = props->num_entries; |
|
|
|
file_to_ingest->num_entries = props->num_entries; |
|
|
|