}
@Override
@SuppressWarnings("resource")
public SSTableWriter read(ReadableByteChannel channel) throws IOException
{
<BUG>logger.debug("reading file from {}, repairedAt = {}", session.peer, repairedAt);</BUG>
long totalSize = totalSize();
<BUG>Pair<String, String> kscf = Schema.instance.getCF(cfId);
if (kscf == null)

{</BUG>
throw new IOException("CF " + cfId + " was dropped during streaming");

}
@Override
@SuppressWarnings("resource")
public SSTableWriter read(ReadableByteChannel channel) throws IOException
{
long totalSize = totalSize();
Pair<String, String> kscf = Schema.instance.getCF(cfId);
ColumnFamilyStore cfs = null;
if (kscf != null)
cfs = Keyspace.open(kscf.left).getColumnFamilyStore(kscf.right);
if (kscf == null || cfs == null)
{
throw new IOException("CF " + cfId + " was dropped during streaming");
