[CASSANDRA-6129] get java.util.ConcurrentModificationException while bulkloading from sstable for widerow table

• Type: Bug
• Status: Resolved
• Priority: Normal
• Resolution: Fixed
• Fix Version/s: 2.0.2
• Component/s: Legacy/Tools

Environment

three cassandra 2.0.1 node
jdk 7
linux - ubuntu

• Severity: Normal
• Since Version: 2.0.0
• Assignee: Jonathan Ellis
• Reporter: koray sariteke

Authors

Jonathan Ellis

Reviewers

Mikhail Stepura

• Tester: koray sariteke
• Created: 02/Oct/13 06:12
• Updated: 16/Apr/19 09:32
• Resolved: 05/Oct/13 00:43

Description

I haven't faced that problem with cassandra 1.2.6

I have created widerow sstables with SSTableSimpleUnsortedWriter. When i tried to load sstables by sstableloader, I got java.util.ConcurrentModificationException after a while (not at the beggining of the streaming).

Exception is :
progress: [/192.168.103.5 0/39 (0%)] [/192.168.103.3 0/39 (0%)] [/192.168.103.1 0/39 (0%)] [total: 0% - 15MB/s (avg: 0MB/s)] INFO 00:45:23,542 Stream #c0f53e00-2ae2-11e3-ab6b-99a3e9e32246 Session with /192.168.103.3 is complete
progress: [/192.168.103.5 0/39 (0%)] [/192.168.103.3 0/39 (0%)] [/192.168.103.1 0/39 (0%)] [total: 0% - 3MB/s (avg: 1MB/s)]Exception in thread "STREAM-OUT-/192.168.103.3" java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextEntry(HashMap.java:894)
at java.util.HashMap$EntryIterator.next(HashMap.java:934)
at java.util.HashMap$EntryIterator.next(HashMap.java:932)
at org.apache.cassandra.tools.BulkLoader$ProgressIndicator.handleStreamEvent(BulkLoader.java:129)
at org.apache.cassandra.streaming.StreamResultFuture.fireStreamEvent(StreamResultFuture.java:198)
at org.apache.cassandra.streaming.StreamResultFuture.handleProgress(StreamResultFuture.java:191)
at org.apache.cassandra.streaming.StreamSession.progress(StreamSession.java:474)
at org.apache.cassandra.streaming.StreamWriter.write(StreamWriter.java:105)
at org.apache.cassandra.streaming.messages.FileMessage$1.serialize(FileMessage.java:73)
at org.apache.cassandra.streaming.messages.FileMessage$1.serialize(FileMessage.java:45)
at org.apache.cassandra.streaming.messages.StreamMessage.serialize(StreamMessage.java:44)
at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.sendMessage(ConnectionHandler.java:384)
at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.run(ConnectionHandler.java:357)
at java.lang.Thread.run(Thread.java:781)
progress: [/192.168.103.5 0/39 (3%)] [/192.168.103.3 0/39 (0%)] [/192.168.103.1 0/39 (2%)] [total: 1% - 2147483647MB/s (avg: 12MB/s)]Exception in thread "STREAM-OUT-/192.168.103.1" java.util.ConcurrentModificationException
at java.util.HashMap$HashIterator.nextEntry(HashMap.java:894)
at java.util.HashMap$KeyIterator.next(HashMap.java:928)
progress: [/192.168.103.5 0/39 (3%)] [/192.168.103.3 0/39 (0%)] [/192.168.103.1 0/39 (2%)] [total: 1% - 2147483647MB/s (avg: 12MB/s)]
at org.apache.cassandra.streaming.StreamResultFuture.fireStreamEvent(StreamResultFuture.java:198)
at org.apache.cassandra.streaming.StreamResultFuture.handleProgress(StreamResultFuture.java:191)
at org.apache.cassandra.streaming.StreamSession.progress(StreamSession.java:474)
at org.apache.cassandra.streaming.StreamWriter.write(StreamWriter.java:105)
at org.apache.cassandra.streaming.messages.FileMessage$1.serialize(FileMessage.java:73)
at org.apache.cassandra.streaming.messages.FileMessage$1.serialize(FileMessage.java:45)
at org.apache.cassandra.streaming.messages.StreamMessage.serialize(StreamMessage.java:44)
at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.sendMessage(ConnectionHandler.java:384)
at org.apache.cassandra.streaming.ConnectionHandler$OutgoingMessageHandler.run(ConnectionHandler.java:357)
at java.lang.Thread.run(Thread.java:781)