[ https://issues.apache.org/jira/browse/CASSANDRA-3283?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13129425#comment-13129425 ]
Jackson Chung edited comment on CASSANDRA-3283 at 10/18/11 2:19 AM: -------------------------------------------------------------------- i can't reproduce this in 1.0.0 (or at least using a test case that reproduced this in 0.8 branch) In my 0.8 test, i noticed this in the log: DEBUG [RMI TCP Connection(9)-192.168.1.142] 2011-10-17 15:28:58,552 StorageService.java (line 2049) Table Keyspace1: work map {localhost/127.0.0.1=[(0,113427455640312821154458202477256070485], (113427455640312821154458202477256070485,0]]}. but in my 1.0.0 test, it shows: DEBUG [RMI TCP Connection(12)-192.168.11.6] 2011-10-17 18:57:41,288 StorageService.java (line 2125) Table Keyspace1: work map {} Looking at the diff, I patched the fix of Bootstrapper.java from CASSANDRA-957: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/dht/BootStrapper.java?r1=1165468&r2=1165467&pathrev=1165468&diff_format=h Now in 0.8 test it shows the same like 1.0.0 and no data are duplicated in itself so i think this problem only exist in 0.8 branch, and no need to be fixed in 1.0 branch or trunk. (though I am not sure if there would be any side effect if just patching the Bootstrapper.java from CASSANDRA-957 was (Author: cywjackson): i can't reproduce this in 1.0.0 (or at least using a test case that reproduced this in 0.8 branch) In my 0.8 test, i noticed this in the log: DEBUG [RMI TCP Connection(9)-192.168.1.142] 2011-10-17 15:28:58,552 StorageService.java (line 2049) Table Keyspace1: work map {localhost/127.0.0.1=[(0,113427455640312821154458202477256070485], (113427455640312821154458202477256070485,0]]}. but in my 1.0.0 test, it shows: DEBUG [RMI TCP Connection(12)-192.168.11.6] 2011-10-17 18:57:41,288 StorageService.java (line 2125) Table Keyspace1: work map {} Looking at the diff, I patched the fix of Bootstrapper.java from cassandra-957: http://svn.apache.org/viewvc/cassandra/trunk/src/java/org/apache/cassandra/dht/BootStrapper.java?r1=1165468&r2=1165467&pathrev=1165468&diff_format=h Now in 0.8 test it shows the same like 1.0.0 and no data are duplicated in itself so i think this problem only exist in 0.8 branch, and no need to be fixed in 1.0 branch or trunk. (though I am not sure if there would be any side effect if just patching the Bootstrapper.java from cassandra-957 > node is sending streams to itself during move operation > ------------------------------------------------------- > > Key: CASSANDRA-3283 > URL: https://issues.apache.org/jira/browse/CASSANDRA-3283 > Project: Cassandra > Issue Type: Bug > Components: Core > Affects Versions: 0.8.6 > Environment: linux debian stable (squeeze), cassandra 0.8.6, java 6 > Update 26 > Reporter: Zenek Kraweznik > Assignee: Nick Bailey > Priority: Minor > Fix For: 1.0.1 > > > I'm moving node 10.10.10.231 from 113427455640312821154458202477256070485 to > 0. > ring: > Address DC Rack Status State Load Owns > Token > > 127605887595351923798765477786913079296 > 10.10.10.232 datacenter1 rack1 Up Normal 148.7 GB 50.00% > 42535295865117307932921825928971026432 > 10.10.10.233 datacenter1 rack1 Up Normal 156.77 GB 25.00% > 85070591730234615865843651857942052864 > 10.10.10.231 datacenter1 rack1 Up Moving 188.75 GB 16.67% > 113427455640312821154458202477256070485 > 10.10.10.234 datacenter1 rack1 Up Normal 94.89 GB 8.33% > 127605887595351923798765477786913079296 > netstats from node1: > Streaming to: /10.10.10.234 > /var/lib/cassandra/data/testdb2/ChangeLog-g-30-Data.db sections=2 > progress=0/6859992288 - 0% > /var/lib/cassandra/data/testdb2/ChangeLogIndex-g-10-Data.db sections=1 > progress=0/15286 - 0% > /var/lib/cassandra/data/testdb/ChangeLogIndex-g-48-Data.db sections=1 > progress=0/90 - 0% > /var/lib/cassandra/data/testdb/Testcoll-g-107-Data.db sections=2 > progress=0/5276 - 0% > /var/lib/cassandra/data/testdb/Testcoll2-g-74-Data.db sections=2 > progress=0/470 - 0% > /var/lib/cassandra/data/testdb/ChangeLogIndex-g-47-Data.db sections=1 > progress=0/1156 - 0% > /var/lib/cassandra/data/testdb/Testcoll-g-106-Data.db sections=2 > progress=0/329027714 - 0% > /var/lib/cassandra/data/testdb/ChangeLog-g-61-Data.db sections=2 > progress=0/30212596 - 0% > /var/lib/cassandra/data/testdb3/Testcoll2-g-42-Data.db sections=2 > progress=0/774117 - 0% > /var/lib/cassandra/data/testdb3/ChangeLogIndex-g-10-Data.db sections=1 > progress=0/90 - 0% > Streaming to: /10.10.10.231 > /var/lib/cassandra/data/testdb2/Testcoll-g-30-Data.db sections=2 > progress=39059456000/87950308260 - 44% > /var/lib/cassandra/data/testdb2/ChangeLog-g-30-Data.db sections=2 > progress=0/7806077255 - 0% > /var/lib/cassandra/data/testdb2/ChangeLogIndex-g-10-Data.db sections=1 > progress=0/15286 - 0% > /var/lib/cassandra/data/testdb3/Testcoll2-g-42-Data.db sections=2 > progress=0/784033 - 0% > /var/lib/cassandra/data/testdb3/ChangeLogIndex-g-10-Data.db sections=1 > progress=0/90 - 0% > /var/lib/cassandra/data/testdb/ChangeLogIndex-g-48-Data.db sections=1 > progress=0/90 - 0% > /var/lib/cassandra/data/testdb/Testcoll-g-107-Data.db sections=2 > progress=0/10499 - 0% > /var/lib/cassandra/data/testdb/Testcoll2-g-74-Data.db sections=2 > progress=0/1042 - 0% > /var/lib/cassandra/data/testdb/ChangeLogIndex-g-47-Data.db sections=1 > progress=0/1156 - 0% > /var/lib/cassandra/data/testdb/Testcoll-g-106-Data.db sections=2 > progress=0/329965993 - 0% > /var/lib/cassandra/data/testdb/ChangeLog-g-61-Data.db sections=2 > progress=0/24633913 - 0% > Streaming from: /10.10.10.231 > testdb: /var/lib/cassandra/data/testdb/ChangeLogIndex-g-47-Data.db > sections=1 progress=0/1156 - 0% > testdb: /var/lib/cassandra/data/testdb/ChangeLogIndex-g-48-Data.db > sections=1 progress=0/90 - 0% > testdb: /var/lib/cassandra/data/testdb/ChangeLog-g-61-Data.db sections=2 > progress=0/24633913 - 0% > testdb3: /var/lib/cassandra/data/testdb3/Testcoll2-g-42-Data.db sections=2 > progress=0/784033 - 0% > testdb: /var/lib/cassandra/data/testdb/Testcoll2-g-74-Data.db sections=2 > progress=0/1042 - 0% > testdb3: /var/lib/cassandra/data/testdb3/ChangeLogIndex-g-10-Data.db > sections=1 progress=0/90 - 0% > testdb2: /var/lib/cassandra/data/testdb2/ChangeLog-g-30-Data.db sections=2 > progress=0/7806077255 - 0% > testdb2: /var/lib/cassandra/data/testdb2/ChangeLogIndex-g-10-Data.db > sections=1 progress=0/15286 - 0% > testdb: /var/lib/cassandra/data/testdb/Testcoll-g-106-Data.db sections=2 > progress=0/329965993 - 0% > testdb2: /var/lib/cassandra/data/testdb2/Testcoll-g-30-Data.db sections=2 > progress=39059456000/87950308260 - 44% > testdb: /var/lib/cassandra/data/testdb/Testcoll-g-107-Data.db sections=2 > progress=0/10499 - 0% > Pool Name Active Pending Completed > Commands n/a 0 23 > Responses n/a 0 13453 -- This message is automatically generated by JIRA. If you think it was sent incorrectly, please contact your JIRA administrators: https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa For more information on JIRA, see: http://www.atlassian.com/software/jira