if (kscf == null)

{</BUG>
throw new IOException("CF " + cfId + " was dropped during streaming");
}
<BUG>ColumnFamilyStore cfs = Keyspace.open(kscf.left).getColumnFamilyStore(kscf.right);
CompressedInputStream cis = new CompressedInputStream(Channels.newInputStream(channel), compressionInfo);</BUG>
BytesReadTracker in = new BytesReadTracker(new DataInputStream(cis));
<BUG>SSTableWriter writer = null;
try</BUG>
{

}
@Override
@SuppressWarnings("resource")
public SSTableWriter read(ReadableByteChannel channel) throws IOException
