assert(m_dataSourcesByPartition.containsKey(partitionId));
assert(m_dataSourcesByPartition.get(partitionId).containsKey(signature));
HashMap<String, ExportDataSource> sources = m_dataSourcesByPartition.get(partitionId);
if (sources == null) {
exportLog.error("Could not find export data sources for partition "
<BUG>+ partitionId + " generation " + m_timestamp + " the export data is being discarded");
DBBPool.wrapBB(buffer).discard();
return;</BUG>
}
ExportDataSource source = sources.get(signature);

assert(m_dataSourcesByPartition.containsKey(partitionId));
assert(m_dataSourcesByPartition.get(partitionId).containsKey(signature));
HashMap<String, ExportDataSource> sources = m_dataSourcesByPartition.get(partitionId);
if (sources == null) {
exportLog.error("Could not find export data sources for partition "
+ partitionId + " generation " + m_timestamp + " the export data is being discarded");
if (buffer != null) {
DBBPool.wrapBB(buffer).discard();
}
return;
}
ExportDataSource source = sources.get(signature);
