[ https://issues.apache.org/jira/browse/CASSANDRA-11957?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Imran Chaudhry updated CASSANDRA-11957: --------------------------------------- Reproduced In: 3.x Tester: Joshua McKenzie Status: Patch Available (was: In Progress) 1) Added seek() to EncryptedFileSegmentInputStream 2) Added unit test for seek to SeqmentReaderTest 3) Modified CommitLogReader to use EncryptedFileSegmentInputStream.seek() > Implement seek() of > org.apache.cassandra.db.commitlog.EncryptedFileSegmentInputStream > -------------------------------------------------------------------------------------- > > Key: CASSANDRA-11957 > URL: https://issues.apache.org/jira/browse/CASSANDRA-11957 > Project: Cassandra > Issue Type: Improvement > Components: Coordination, Local Write-Read Paths > Reporter: Imran Chaudhry > Assignee: Imran Chaudhry > Priority: Critical > Fix For: 3.x > > > CDC needs the seek() method of > org.apache.cassandra.db.commitlog.EncryptedFileSegmentInputStream implemented > (currently throws an exception.) > CommitLogs are read using this stream and the seek() method needs to be > implemented so that mutations which are appended to the currently active > commitlog can be read out in realtime. > > Current implementation is: > > public void seek(long position) > { > // implement this when we actually need it > throw new UnsupportedOperationException(); > } -- This message was sent by Atlassian JIRA (v6.3.4#6332)