[ https://issues.apache.org/jira/browse/CASSANDRA-1189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nirmal Ranganathan updated CASSANDRA-1189: ------------------------------------------ Attachment: 0002-Test-cases-for-Streaming-Messages.patch 0003-1189-Fixes-v1.patch Updated most of the suggested changes, I wasn't able to simplify StreamHeader, StreamContext and PendingFile. I've run various test for Request & Transfer and seems good, however there was one case when I got an error flushing the SSTable, looks like compaction happened before the file transfer could be completed, on a request. I'm trying to reproduce that, in the meantime here's the patch with updates. > Refactor streaming > ------------------ > > Key: CASSANDRA-1189 > URL: https://issues.apache.org/jira/browse/CASSANDRA-1189 > Project: Cassandra > Issue Type: Improvement > Components: Core > Affects Versions: 0.7 beta 1 > Reporter: Gary Dusbabek > Assignee: Nirmal Ranganathan > Priority: Critical > Fix For: 0.7.0 > > Attachments: > 0001-Refactored-streaming-to-make-it-more-streamlined.patch, > 0002-Test-cases-for-Streaming-Messages.patch, 0003-1189-Fixes-v1.patch > > > The current architecture is buggy because it makes the assumption that only > one stream can be in process between two nodes at a given time, and stream > send order never changes. Because of this, the ACK process gets fouled up > when other services wish to stream files. > The process is somewhat contorted too (request, initiate, initiate done, > send). -- This message is automatically generated by JIRA. - You can reply to this email to add a comment to the issue online.