Ubuntu
apache package

cassandra - crash in compaction using lucid ppa package

Bug #725470 reported by Robert Collins
8
This bug affects 1 person
Affects Status Importance Assigned to Milestone
cassandra-packages
Won't Fix
Critical
Clint Byrum
apache (Ubuntu)
Invalid
Undecided
Unassigned

Bug Description

ERROR [CompactionExecutor:1] 2011-02-26 21:07:35,264 AbstractCassandraDaemon.java (line 91) Fatal exception in thread Thread[CompactionExecutor:1,1,main]
java.lang.NoClassDefFoundError: org/apache/commons/collections/PredicateUtils
        at org.apache.cassandra.db.CompactionManager.doCompaction(CompactionManager.java:305)
        at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:122)
        at org.apache.cassandra.db.CompactionManager$1.call(CompactionManager.java:92)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
        at java.util.concurrent.FutureTask.run(FutureTask.java:166)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
        at java.lang.Thread.run(Thread.java:636)

Related branches

lp:~clint-fewbar/cassandra-packages/0.7
lp:cassandra-packages/lucid
Roger Mbiama Assogo: Pending requested
Diff: 143950 lines (+83047/-34787)
667 files modified
.rat-excludes (+9/-1)
CHANGES.txt (+436/-43)
NEWS.txt (+152/-1)
NOTICE.txt (+9/-0)
README.txt (+33/-26)
bin/cassandra (+17/-8)
bin/cassandra.bat (+5/-4)
bin/cassandra.in.sh (+8/-22)
bin/clustertool.bat (+67/-0)
bin/config-converter (+50/-0)
bin/config-converter.bat (+67/-0)
bin/json2sstable.bat (+2/-3)
bin/nodeprobe (+0/-62)
bin/nodetool.bat (+2/-2)
bin/schematool (+49/-0)
bin/schematool.bat (+67/-0)
bin/sstable2json.bat (+2/-3)
bin/sstablekeys (+1/-1)
bin/sstablekeys.bat (+61/-0)
build.xml (+500/-142)
conf/README.txt (+13/-0)
conf/access.properties (+23/-6)
conf/cassandra-env.sh (+162/-0)
conf/cassandra-topology.properties (+37/-0)
conf/cassandra.yaml (+487/-0)
conf/log4j-server.properties (+41/-0)
conf/log4j.properties (+0/-40)
conf/storage-conf.xml (+0/-413)
contrib/bmt_example/CassandraBulkLoader.java (+32/-33)
contrib/cassandra_browser/README (+0/-139)
contrib/cassandra_browser/cutejson.py (+0/-116)
contrib/cassandra_browser/index.py (+0/-485)
contrib/circuit/src/org/apache/cassandra/contrib/circuit/RingModel.java (+1/-1)
contrib/client_only/ClientOnlyExample.java (+0/-175)
contrib/client_only/README.txt (+49/-0)
contrib/client_only/bin/client_only (+56/-0)
contrib/client_only/build.xml (+69/-0)
contrib/client_only/conf/cassandra.yaml (+462/-0)
contrib/client_only/src/ClientOnlyExample.java (+194/-0)
contrib/hadoop_streaming_output/README.txt (+24/-0)
contrib/hadoop_streaming_output/bin/mapper.py (+43/-0)
contrib/hadoop_streaming_output/bin/reducer.py (+72/-0)
contrib/hadoop_streaming_output/bin/streaming (+40/-0)
contrib/javautils/build.xml (+7/-2)
contrib/javautils/src/main/java/org/apache/cassandra/contrib/utils/service/CassandraServiceDataCleaner.java (+8/-15)
contrib/javautils/src/test/java/org/apache/cassandra/contrib/utils/service/CassandraServiceTest.java (+53/-18)
contrib/maven/pom.xml (+0/-551)
contrib/mutex/README (+0/-9)
contrib/mutex/cassandra.patch (+0/-50)
contrib/mutex/src/org/apache/cassandra/mutex/ClusterMutex.java (+0/-343)
contrib/mutex/storage-conf.xml (+0/-43)
contrib/pig/README.txt (+10/-5)
contrib/pig/build.xml (+1/-1)
contrib/pig/example-script.pig (+1/-1)
contrib/pig/src/java/org/apache/cassandra/hadoop/pig/CassandraStorage.java (+34/-11)
contrib/pig/storage-conf.xml (+0/-369)
contrib/property_snitch/README.txt (+0/-41)
contrib/property_snitch/build.xml (+0/-77)
contrib/property_snitch/conf/rack.properties (+0/-23)
contrib/property_snitch/src/java/org/apache/cassandra/locator/PropertyFileEndPointSnitch.java (+0/-189)
contrib/property_snitch/src/java/org/apache/cassandra/locator/PropertyFileEndPointSnitchMBean.java (+0/-47)
contrib/py_stress/README.txt (+4/-2)
contrib/py_stress/avro_stress.py (+376/-0)
contrib/py_stress/stress.py (+226/-56)
contrib/redhat/cassandra (+0/-48)
contrib/stress/README.txt (+59/-0)
contrib/stress/bin/stress (+49/-0)
contrib/stress/build.xml (+56/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/Session.java (+406/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/Stress.java (+177/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/operations/IndexedRangeSlicer.java (+121/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/operations/Inserter.java (+137/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/operations/MultiGetter.java (+136/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/operations/RangeSlicer.java (+139/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/operations/Reader.java (+145/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/util/OperationThread.java (+189/-0)
contrib/stress/src/org/apache/cassandra/contrib/stress/util/Range.java (+72/-0)
contrib/word_count/README.txt (+13/-7)
contrib/word_count/bin/word_count (+3/-1)
contrib/word_count/bin/word_count_setup (+5/-1)
contrib/word_count/build.xml (+1/-1)
contrib/word_count/src/WordCount.java (+108/-43)
contrib/word_count/src/WordCountSetup.java (+101/-37)
contrib/word_count/storage-conf.xml (+0/-382)
debian/TODO (+0/-2)
debian/cassandra.conf (+2/-0)
debian/cassandra.default (+0/-20)
debian/cassandra.in.sh (+0/-17)
debian/cassandra.install (+6/-3)
debian/cassandra.postinst (+55/-0)
debian/changelog (+153/-1)
debian/control (+41/-2)
debian/default (+7/-0)
debian/init (+82/-32)
debian/patches/fix-maven-download.patch (+40/-0)
debian/patches/no-ivy-download.patch (+50/-9)
debian/patches/raise-test-timeout.patch (+17/-0)
debian/patches/series (+2/-1)
debian/rules (+62/-8)
debian/source/include-binaries (+12/-13)
interface/cassandra.avpr (+0/-100)
interface/cassandra.genavro (+378/-0)
interface/cassandra.thrift (+204/-119)
interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationException.java (+38/-27)
interface/thrift/gen-java/org/apache/cassandra/thrift/AuthenticationRequest.java (+67/-36)
interface/thrift/gen-java/org/apache/cassandra/thrift/AuthorizationException.java (+37/-26)
interface/thrift/gen-java/org/apache/cassandra/thrift/Cassandra.java (+14426/-8362)
interface/thrift/gen-java/org/apache/cassandra/thrift/CfDef.java (+2147/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/Column.java (+194/-64)
interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnDef.java (+657/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnOrSuperColumn.java (+48/-28)
interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnParent.java (+66/-41)
interface/thrift/gen-java/org/apache/cassandra/thrift/ColumnPath.java (+95/-56)
interface/thrift/gen-java/org/apache/cassandra/thrift/ConsistencyLevel.java (+17/-21)
interface/thrift/gen-java/org/apache/cassandra/thrift/Constants.java (+3/-1)
interface/thrift/gen-java/org/apache/cassandra/thrift/Deletion.java (+77/-42)
interface/thrift/gen-java/org/apache/cassandra/thrift/IndexClause.java (+585/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/IndexExpression.java (+573/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/IndexOperator.java (+74/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/IndexType.java (+62/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/InvalidRequestException.java (+37/-26)
interface/thrift/gen-java/org/apache/cassandra/thrift/KeyCount.java (+448/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/KeyRange.java (+132/-62)
interface/thrift/gen-java/org/apache/cassandra/thrift/KeySlice.java (+82/-51)
interface/thrift/gen-java/org/apache/cassandra/thrift/KsDef.java (+810/-0)
interface/thrift/gen-java/org/apache/cassandra/thrift/Mutation.java (+48/-28)
interface/thrift/gen-java/org/apache/cassandra/thrift/NotFoundException.java (+25/-23)
interface/thrift/gen-java/org/apache/cassandra/thrift/SlicePredicate.java (+62/-42)
interface/thrift/gen-java/org/apache/cassandra/thrift/SliceRange.java (+111/-61)
interface/thrift/gen-java/org/apache/cassandra/thrift/SuperColumn.java (+66/-41)
interface/thrift/gen-java/org/apache/cassandra/thrift/TimedOutException.java (+25/-23)
interface/thrift/gen-java/org/apache/cassandra/thrift/TokenRange.java (+69/-40)
interface/thrift/gen-java/org/apache/cassandra/thrift/UnavailableException.java (+25/-23)
ivy.xml (+0/-36)
ivysettings.xml (+0/-31)
lib/licenses/avro-1.3.1-dev.txt (+202/-0)
lib/licenses/clhm-production.txt (+0/-202)
lib/licenses/concurrentlinkedhashmap-lru-1.1.txt (+202/-0)
lib/licenses/google-collections-1.0.txt (+0/-202)
lib/licenses/guava-r05.txt (+202/-0)
lib/licenses/hadoop-core-0.20.1.txt (+0/-202)
lib/licenses/jetty-6.1.21.txt (+202/-0)
lib/licenses/jetty-util-6.1.21.txt (+202/-0)
lib/licenses/jug-2.0.0.txt (+202/-0)
lib/licenses/libthrift-0.5.txt (+202/-0)
lib/licenses/libthrift-r917130.txt (+0/-202)
lib/licenses/log4j-1.2.14.txt (+0/-202)
lib/licenses/log4j-1.2.16.txt (+202/-0)
lib/licenses/servlet-api-2.5-20081211.txt (+202/-0)
lib/licenses/slf4j-api-1.5.8.txt (+0/-20)
lib/licenses/slf4j-api-1.6.1.txt (+20/-0)
lib/licenses/slf4j-log4j12-1.5.8.txt (+0/-20)
lib/licenses/slf4j-log4j12-1.6.1.txt (+20/-0)
lib/licenses/snakeyaml-1.6.txt (+202/-0)
redhat/apache-cassandra.spec (+22/-9)
redhat/cassandra (+51/-0)
redhat/cassandra.conf (+1/-0)
redhat/cassandra.in.sh (+13/-0)
redhat/default (+7/-0)
src/avro/internode.genavro (+85/-0)
src/java/org/apache/cassandra/auth/AllowAllAuthenticator.java (+20/-6)
src/java/org/apache/cassandra/auth/AllowAllAuthority.java (+41/-0)
src/java/org/apache/cassandra/auth/AuthenticatedUser.java (+52/-0)
src/java/org/apache/cassandra/auth/IAuthenticator.java (+14/-3)
src/java/org/apache/cassandra/auth/IAuthority.java (+66/-0)
src/java/org/apache/cassandra/auth/Permission.java (+38/-0)
src/java/org/apache/cassandra/auth/Resources.java (+51/-0)
src/java/org/apache/cassandra/auth/SimpleAuthenticator.java (+45/-54)
src/java/org/apache/cassandra/auth/SimpleAuthority.java (+157/-0)
src/java/org/apache/cassandra/avro/AvroRecordFactory.java (+202/-0)
src/java/org/apache/cassandra/avro/AvroValidation.java (+336/-0)
src/java/org/apache/cassandra/avro/CassandraDaemon.java (+83/-0)
src/java/org/apache/cassandra/avro/CassandraServer.java (+1147/-0)
src/java/org/apache/cassandra/avro/KeyspaceNotDefinedException.java (+34/-0)
src/java/org/apache/cassandra/cache/AbstractCache.java (+5/-2)
src/java/org/apache/cassandra/cache/ICacheExpungeHook.java (+0/-24)
src/java/org/apache/cassandra/cache/InstrumentedCache.java (+16/-6)
src/java/org/apache/cassandra/cli/Cli.g (+449/-105)
src/java/org/apache/cassandra/cli/CliClient.java (+1933/-345)
src/java/org/apache/cassandra/cli/CliCompiler.java (+83/-32)
src/java/org/apache/cassandra/cli/CliCompleter.java (+30/-2)
src/java/org/apache/cassandra/cli/CliMain.java (+267/-140)
src/java/org/apache/cassandra/cli/CliOptions.java (+171/-74)
src/java/org/apache/cassandra/cli/CliSessionState.java (+43/-7)
src/java/org/apache/cassandra/cli/CliUserHelp.java (+384/-0)
src/java/org/apache/cassandra/cli/CliUtils.java (+111/-24)
src/java/org/apache/cassandra/client/RingCache.java (+80/-54)
src/java/org/apache/cassandra/concurrent/AIOExecutorService.java (+1/-11)
src/java/org/apache/cassandra/concurrent/DebuggableThreadPoolExecutor.java (+3/-2)
src/java/org/apache/cassandra/concurrent/JMXConfigurableThreadPoolExecutor.java (+3/-2)
src/java/org/apache/cassandra/concurrent/JMXEnabledThreadPoolExecutor.java (+17/-5)
src/java/org/apache/cassandra/concurrent/NamedThreadFactory.java (+2/-2)
src/java/org/apache/cassandra/concurrent/RetryingScheduledThreadPoolExecutor.java (+8/-4)
src/java/org/apache/cassandra/concurrent/Stage.java (+65/-0)
src/java/org/apache/cassandra/concurrent/StageManager.java (+24/-31)
src/java/org/apache/cassandra/config/CFMetaData.java (+899/-44)
src/java/org/apache/cassandra/config/ColumnDefinition.java (+183/-0)
src/java/org/apache/cassandra/config/Config.java (+126/-0)
src/java/org/apache/cassandra/config/ConfigurationException.java (+23/-21)
src/java/org/apache/cassandra/config/Converter.java (+355/-0)
src/java/org/apache/cassandra/config/DatabaseDescriptor.java (+818/-903)
src/java/org/apache/cassandra/config/KSMetaData.java (+101/-30)
src/java/org/apache/cassandra/config/RawColumnDefinition.java (+32/-0)
src/java/org/apache/cassandra/config/RawColumnFamily.java (+49/-0)
src/java/org/apache/cassandra/config/RawKeyspace.java (+36/-0)
src/java/org/apache/cassandra/config/ReplicationStrategy.java (+30/-0)
src/java/org/apache/cassandra/config/RequestSchedulerOptions.java (+36/-0)
src/java/org/apache/cassandra/db/BinaryMemtable.java (+24/-18)
src/java/org/apache/cassandra/db/BinaryVerbHandler.java (+8/-8)
src/java/org/apache/cassandra/db/Column.java (+77/-66)
src/java/org/apache/cassandra/db/ColumnFamily.java (+193/-174)
src/java/org/apache/cassandra/db/ColumnFamilySerializer.java (+35/-59)
src/java/org/apache/cassandra/db/ColumnFamilyStore.java (+1416/-731)
src/java/org/apache/cassandra/db/ColumnFamilyStoreMBean.java (+65/-6)
src/java/org/apache/cassandra/db/ColumnFamilyType.java (+40/-0)
src/java/org/apache/cassandra/db/ColumnIndexer.java (+72/-89)
src/java/org/apache/cassandra/db/ColumnSerializer.java (+62/-45)
src/java/org/apache/cassandra/db/CompactionManager.java (+608/-268)
src/java/org/apache/cassandra/db/CompactionManagerMBean.java (+18/-19)
src/java/org/apache/cassandra/db/DBConstants.java (+2/-1)
src/java/org/apache/cassandra/db/DecoratedKey.java (+6/-29)
src/java/org/apache/cassandra/db/DefinitionsAnnounceVerbHandler.java (+36/-0)
src/java/org/apache/cassandra/db/DefinitionsUpdateResponseVerbHandler.java (+94/-0)
src/java/org/apache/cassandra/db/DefsTable.java (+123/-0)
src/java/org/apache/cassandra/db/DeletedColumn.java (+65/-0)
src/java/org/apache/cassandra/db/ExpiringColumn.java (+138/-0)
src/java/org/apache/cassandra/db/HintedHandOffManager.java (+327/-125)
src/java/org/apache/cassandra/db/HintedHandOffManagerMBean.java (+46/-0)
src/java/org/apache/cassandra/db/IColumn.java (+18/-7)
src/java/org/apache/cassandra/db/IFlushable.java (+2/-2)
src/java/org/apache/cassandra/db/IndexScanCommand.java (+107/-0)
src/java/org/apache/cassandra/db/Memtable.java (+80/-86)
src/java/org/apache/cassandra/db/RangeSliceCommand.java (+18/-18)
src/java/org/apache/cassandra/db/RangeSliceReply.java (+9/-6)
src/java/org/apache/cassandra/db/ReadCommand.java (+6/-9)
src/java/org/apache/cassandra/db/ReadRepairVerbHandler.java (+11/-8)
src/java/org/apache/cassandra/db/ReadResponse.java (+27/-31)
src/java/org/apache/cassandra/db/ReadVerbHandler.java (+25/-30)
src/java/org/apache/cassandra/db/Row.java (+11/-10)
src/java/org/apache/cassandra/db/RowIterator.java (+72/-0)
src/java/org/apache/cassandra/db/RowIteratorFactory.java (+215/-0)
src/java/org/apache/cassandra/db/RowMutation.java (+131/-122)
src/java/org/apache/cassandra/db/RowMutationMessage.java (+0/-86)
src/java/org/apache/cassandra/db/RowMutationVerbHandler.java (+55/-18)
src/java/org/apache/cassandra/db/SchemaCheckVerbHandler.java (+40/-0)
src/java/org/apache/cassandra/db/SliceByNamesReadCommand.java (+19/-15)
src/java/org/apache/cassandra/db/SliceFromReadCommand.java (+17/-13)
src/java/org/apache/cassandra/db/SuperColumn.java (+74/-40)
src/java/org/apache/cassandra/db/SystemTable.java (+229/-218)
src/java/org/apache/cassandra/db/Table.java (+511/-258)
src/java/org/apache/cassandra/db/TruncateResponse.java (+83/-0)
src/java/org/apache/cassandra/db/TruncateVerbHandler.java (+105/-0)
src/java/org/apache/cassandra/db/Truncation.java (+97/-0)
src/java/org/apache/cassandra/db/UnserializableColumnFamilyException.java (+33/-0)
src/java/org/apache/cassandra/db/WriteResponse.java (+7/-5)
src/java/org/apache/cassandra/db/columniterator/IColumnIterator.java (+49/-0)
src/java/org/apache/cassandra/db/columniterator/IdentityQueryFilter.java (+43/-0)
src/java/org/apache/cassandra/db/columniterator/IndexedSliceReader.java (+231/-0)
src/java/org/apache/cassandra/db/columniterator/SSTableNamesIterator.java (+203/-0)
src/java/org/apache/cassandra/db/columniterator/SSTableSliceIterator.java (+127/-0)
src/java/org/apache/cassandra/db/columniterator/SimpleAbstractColumnIterator.java (+33/-0)
src/java/org/apache/cassandra/db/columniterator/SimpleSliceReader.java (+105/-0)
src/java/org/apache/cassandra/db/commitlog/AbstractCommitLogExecutorService.java (+4/-11)
src/java/org/apache/cassandra/db/commitlog/BatchCommitLogExecutorService.java (+33/-8)
src/java/org/apache/cassandra/db/commitlog/CommitLog.java (+168/-150)
src/java/org/apache/cassandra/db/commitlog/CommitLogHeader.java (+132/-113)
src/java/org/apache/cassandra/db/commitlog/CommitLogSegment.java (+50/-46)
src/java/org/apache/cassandra/db/commitlog/ICommitLogExecutorService.java (+5/-0)
src/java/org/apache/cassandra/db/commitlog/PeriodicCommitLogExecutorService.java (+67/-17)
src/java/org/apache/cassandra/db/filter/AbstractColumnIterator.java (+3/-1)
src/java/org/apache/cassandra/db/filter/ColumnIterator.java (+0/-41)
src/java/org/apache/cassandra/db/filter/IFilter.java (+77/-0)
src/java/org/apache/cassandra/db/filter/IdentityQueryFilter.java (+0/-43)
src/java/org/apache/cassandra/db/filter/NamesQueryFilter.java (+35/-35)
src/java/org/apache/cassandra/db/filter/QueryFilter.java (+129/-45)
src/java/org/apache/cassandra/db/filter/QueryPath.java (+17/-16)
src/java/org/apache/cassandra/db/filter/SSTableNamesIterator.java (+0/-132)
src/java/org/apache/cassandra/db/filter/SSTableSliceIterator.java (+0/-222)
src/java/org/apache/cassandra/db/filter/SimpleAbstractColumnIterator.java (+0/-32)
src/java/org/apache/cassandra/db/filter/SliceQueryFilter.java (+30/-20)
src/java/org/apache/cassandra/db/marshal/AbstractType.java (+24/-27)
src/java/org/apache/cassandra/db/marshal/AsciiType.java (+32/-7)
src/java/org/apache/cassandra/db/marshal/BytesType.java (+29/-10)
src/java/org/apache/cassandra/db/marshal/IntegerType.java (+148/-0)
src/java/org/apache/cassandra/db/marshal/LexicalUUIDType.java (+29/-17)
src/java/org/apache/cassandra/db/marshal/LocalByPartionerType.java (+60/-0)
src/java/org/apache/cassandra/db/marshal/LongType.java (+44/-14)
src/java/org/apache/cassandra/db/marshal/MarshalException.java (+5/-0)
src/java/org/apache/cassandra/db/marshal/TimeUUIDType.java (+72/-32)
src/java/org/apache/cassandra/db/marshal/UTF8Type.java (+139/-10)
src/java/org/apache/cassandra/db/migration/AddColumnFamily.java (+106/-0)
src/java/org/apache/cassandra/db/migration/AddKeyspace.java (+97/-0)
src/java/org/apache/cassandra/db/migration/DropColumnFamily.java (+122/-0)
src/java/org/apache/cassandra/db/migration/DropKeyspace.java (+111/-0)
src/java/org/apache/cassandra/db/migration/Migration.java (+330/-0)
src/java/org/apache/cassandra/db/migration/RenameColumnFamily.java (+134/-0)
src/java/org/apache/cassandra/db/migration/RenameKeyspace.java (+152/-0)
src/java/org/apache/cassandra/db/migration/UpdateColumnFamily.java (+109/-0)
src/java/org/apache/cassandra/db/migration/UpdateKeyspace.java (+97/-0)
src/java/org/apache/cassandra/dht/AbstractBounds.java (+32/-6)
src/java/org/apache/cassandra/dht/AbstractByteOrderedPartitioner.java (+208/-0)
src/java/org/apache/cassandra/dht/BootStrapper.java (+80/-52)
src/java/org/apache/cassandra/dht/Bounds.java (+8/-1)
src/java/org/apache/cassandra/dht/ByteOrderedPartitioner.java (+31/-0)
src/java/org/apache/cassandra/dht/BytesToken.java (+13/-5)
src/java/org/apache/cassandra/dht/CollatingOrderPreservingPartitioner.java (+26/-127)
src/java/org/apache/cassandra/dht/IPartitioner.java (+18/-14)
src/java/org/apache/cassandra/dht/LocalPartitioner.java (+84/-0)
src/java/org/apache/cassandra/dht/LocalToken.java (+65/-0)
src/java/org/apache/cassandra/dht/OrderPreservingPartitioner.java (+77/-38)
src/java/org/apache/cassandra/dht/RandomPartitioner.java (+87/-36)
src/java/org/apache/cassandra/dht/Range.java (+52/-8)
src/java/org/apache/cassandra/dht/StringToken.java (+0/-1)
src/java/org/apache/cassandra/dht/Token.java (+8/-7)
src/java/org/apache/cassandra/gms/ApplicationState.java (+31/-97)
src/java/org/apache/cassandra/gms/EndPointState.java (+0/-200)
src/java/org/apache/cassandra/gms/EndpointState.java (+188/-0)
src/java/org/apache/cassandra/gms/FailureDetector.java (+34/-49)
src/java/org/apache/cassandra/gms/FailureDetectorMBean.java (+2/-0)
src/java/org/apache/cassandra/gms/GossipDigest.java (+12/-13)
src/java/org/apache/cassandra/gms/GossipDigestAck2Message.java (+10/-9)
src/java/org/apache/cassandra/gms/GossipDigestAck2VerbHandler.java (+10/-8)
src/java/org/apache/cassandra/gms/GossipDigestAckMessage.java (+10/-12)
src/java/org/apache/cassandra/gms/GossipDigestAckVerbHandler.java (+22/-14)
src/java/org/apache/cassandra/gms/GossipDigestSynMessage.java (+22/-17)
src/java/org/apache/cassandra/gms/GossipDigestSynVerbHandler.java (+26/-18)
src/java/org/apache/cassandra/gms/Gossiper.java (+339/-260)
src/java/org/apache/cassandra/gms/GossiperJoinVerbHandler.java (+0/-65)
src/java/org/apache/cassandra/gms/IEndPointStateChangePublisher.java (+0/-39)
src/java/org/apache/cassandra/gms/IEndPointStateChangeSubscriber.java (+0/-50)
src/java/org/apache/cassandra/gms/IEndpointStateChangeSubscriber.java (+50/-0)
src/java/org/apache/cassandra/gms/JoinMessage.java (+0/-61)
src/java/org/apache/cassandra/gms/PureRandom.java (+1/-1)
src/java/org/apache/cassandra/gms/VersionedValue.java (+168/-0)
src/java/org/apache/cassandra/hadoop/ColumnFamilyInputFormat.java (+71/-58)
src/java/org/apache/cassandra/hadoop/ColumnFamilyOutputFormat.java (+186/-0)
src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordReader.java (+114/-83)
src/java/org/apache/cassandra/hadoop/ColumnFamilyRecordWriter.java (+381/-0)
src/java/org/apache/cassandra/hadoop/ColumnFamilySplit.java (+5/-11)
src/java/org/apache/cassandra/hadoop/ConfigHelper.java (+110/-39)
src/java/org/apache/cassandra/hadoop/streaming/AvroOutputReader.java (+153/-0)
src/java/org/apache/cassandra/hadoop/streaming/AvroResolver.java (+50/-0)
src/java/org/apache/cassandra/io/AbstractCompactedRow.java (+63/-0)
src/java/org/apache/cassandra/io/BloomFilterTracker.java (+0/-78)
src/java/org/apache/cassandra/io/CompactionIterator.java (+45/-80)
src/java/org/apache/cassandra/io/DeletionService.java (+2/-3)
src/java/org/apache/cassandra/io/ICompactSerializer.java (+1/-2)
src/java/org/apache/cassandra/io/ICompactSerializer2.java (+3/-1)
src/java/org/apache/cassandra/io/ICompactionInfo.java (+31/-0)
src/java/org/apache/cassandra/io/IndexHelper.java (+0/-158)
src/java/org/apache/cassandra/io/IndexSummary.java (+0/-135)
src/java/org/apache/cassandra/io/IteratingRow.java (+0/-114)
src/java/org/apache/cassandra/io/LazilyCompactedRow.java (+223/-0)
src/java/org/apache/cassandra/io/PrecompactedRow.java (+134/-0)
src/java/org/apache/cassandra/io/SSTable.java (+0/-201)
src/java/org/apache/cassandra/io/SSTableDeletingReference.java (+0/-110)
src/java/org/apache/cassandra/io/SSTableReader.java (+0/-598)
src/java/org/apache/cassandra/io/SSTableScanner.java (+0/-149)
src/java/org/apache/cassandra/io/SSTableTracker.java (+0/-248)
src/java/org/apache/cassandra/io/SSTableWriter.java (+0/-169)
src/java/org/apache/cassandra/io/SerDeUtils.java (+124/-0)
src/java/org/apache/cassandra/io/sstable/BloomFilterTracker.java (+78/-0)
src/java/org/apache/cassandra/io/sstable/CacheWriter.java (+110/-0)
src/java/org/apache/cassandra/io/sstable/Component.java (+173/-0)
src/java/org/apache/cassandra/io/sstable/Descriptor.java (+210/-0)
src/java/org/apache/cassandra/io/sstable/IndexHelper.java (+184/-0)
src/java/org/apache/cassandra/io/sstable/IndexSummary.java (+108/-0)
src/java/org/apache/cassandra/io/sstable/KeyIterator.java (+95/-0)
src/java/org/apache/cassandra/io/sstable/ReducingKeyIterator.java (+111/-0)
src/java/org/apache/cassandra/io/sstable/SSTable.java (+266/-0)
src/java/org/apache/cassandra/io/sstable/SSTableDeletingReference.java (+100/-0)
src/java/org/apache/cassandra/io/sstable/SSTableIdentityIterator.java (+157/-0)
src/java/org/apache/cassandra/io/sstable/SSTableReader.java (+681/-0)
src/java/org/apache/cassandra/io/sstable/SSTableScanner.java (+198/-0)
src/java/org/apache/cassandra/io/sstable/SSTableTracker.java (+217/-0)
src/java/org/apache/cassandra/io/sstable/SSTableWriter.java (+420/-0)
src/java/org/apache/cassandra/io/util/AbstractDataInput.java (+348/-0)
src/java/org/apache/cassandra/io/util/BufferedRandomAccessFile.java (+404/-350)
src/java/org/apache/cassandra/io/util/BufferedSegmentedFile.java (+71/-0)
src/java/org/apache/cassandra/io/util/ColumnSortedMap.java (+286/-0)
src/java/org/apache/cassandra/io/util/DataOutputBuffer.java (+23/-54)
src/java/org/apache/cassandra/io/util/FileDataInput.java (+17/-8)
src/java/org/apache/cassandra/io/util/FileMark.java (+23/-0)
src/java/org/apache/cassandra/io/util/FileUtils.java (+59/-18)
src/java/org/apache/cassandra/io/util/IIterableColumns.java (+32/-0)
src/java/org/apache/cassandra/io/util/MappedFileDataInput.java (+89/-362)
src/java/org/apache/cassandra/io/util/MmappedSegmentedFile.java (+181/-0)
src/java/org/apache/cassandra/io/util/OutputBuffer.java (+74/-0)
src/java/org/apache/cassandra/io/util/SegmentedFile.java (+144/-0)
src/java/org/apache/cassandra/locator/AbstractEndpointSnitch.java (+36/-93)
src/java/org/apache/cassandra/locator/AbstractNetworkTopologySnitch.java (+105/-0)
src/java/org/apache/cassandra/locator/AbstractReplicationStrategy.java (+162/-80)
src/java/org/apache/cassandra/locator/DynamicEndpointSnitch.java (+140/-60)
src/java/org/apache/cassandra/locator/DynamicEndpointSnitchMBean.java (+7/-0)
src/java/org/apache/cassandra/locator/Ec2Snitch.java (+95/-0)
src/java/org/apache/cassandra/locator/EndPointSnitch.java (+0/-62)
src/java/org/apache/cassandra/locator/EndpointSnitchInfo.java (+56/-0)
src/java/org/apache/cassandra/locator/EndpointSnitchInfoMBean.java (+42/-0)
src/java/org/apache/cassandra/locator/IEndPointSnitch.java (+0/-66)
src/java/org/apache/cassandra/locator/IEndpointSnitch.java (+62/-0)
src/java/org/apache/cassandra/locator/ILatencyPublisher.java (+0/-26)
src/java/org/apache/cassandra/locator/LocalStrategy.java (+41/-0)
src/java/org/apache/cassandra/locator/NetworkTopologyStrategy.java (+167/-0)
src/java/org/apache/cassandra/locator/OldNetworkTopologyStrategy.java (+105/-0)
src/java/org/apache/cassandra/locator/PropertyFileSnitch.java (+164/-0)
src/java/org/apache/cassandra/locator/RackAwareStrategy.java (+0/-111)
src/java/org/apache/cassandra/locator/RackInferringSnitch.java (+38/-0)
src/java/org/apache/cassandra/locator/RackUnawareStrategy.java (+0/-61)
src/java/org/apache/cassandra/locator/SimpleSnitch.java (+51/-0)
src/java/org/apache/cassandra/locator/SimpleStrategy.java (+65/-0)
src/java/org/apache/cassandra/locator/TokenMetadata.java (+157/-94)
src/java/org/apache/cassandra/net/AsyncResult.java (+36/-55)
src/java/org/apache/cassandra/net/CompactEndPointSerializationHelper.java (+0/-39)
src/java/org/apache/cassandra/net/CompactEndpointSerializationHelper.java (+41/-0)
src/java/org/apache/cassandra/net/FileStreamTask.java (+0/-153)
src/java/org/apache/cassandra/net/Header.java (+23/-47)
src/java/org/apache/cassandra/net/IAsyncCallback.java (+1/-1)
src/java/org/apache/cassandra/net/IAsyncResult.java (+4/-15)
src/java/org/apache/cassandra/net/IMessageCallback.java (+26/-0)
src/java/org/apache/cassandra/net/IVerbHandler.java (+4/-3)
src/java/org/apache/cassandra/net/IncomingTcpConnection.java (+53/-18)
src/java/org/apache/cassandra/net/Message.java (+45/-44)
src/java/org/apache/cassandra/net/MessageDeliveryTask.java (+26/-14)
src/java/org/apache/cassandra/net/MessagingService.java (+226/-185)
src/java/org/apache/cassandra/net/MessagingServiceMBean.java (+52/-0)
src/java/org/apache/cassandra/net/OutboundTcpConnection.java (+24/-7)
src/java/org/apache/cassandra/net/OutboundTcpConnectionPool.java (+5/-4)
src/java/org/apache/cassandra/net/ResponseVerbHandler.java (+27/-41)
src/java/org/apache/cassandra/net/sink/IMessageSink.java (+2/-1)
src/java/org/apache/cassandra/net/sink/SinkManager.java (+30/-36)
src/java/org/apache/cassandra/scheduler/IRequestScheduler.java (+41/-0)
src/java/org/apache/cassandra/scheduler/NoScheduler.java (+40/-0)
src/java/org/apache/cassandra/scheduler/RoundRobinScheduler.java (+161/-0)
src/java/org/apache/cassandra/service/AbstractCassandraDaemon.java (+410/-0)
src/java/org/apache/cassandra/service/AbstractWriteResponseHandler.java (+77/-0)
src/java/org/apache/cassandra/service/AntiEntropyService.java (+354/-206)
src/java/org/apache/cassandra/service/CassandraDaemon.java (+78/-0)
src/java/org/apache/cassandra/service/ClientState.java (+176/-0)
src/java/org/apache/cassandra/service/ConsistencyChecker.java (+0/-196)
src/java/org/apache/cassandra/service/DatacenterReadCallback.java (+101/-0)
src/java/org/apache/cassandra/service/DatacenterSyncWriteResponseHandler.java (+118/-0)
src/java/org/apache/cassandra/service/DatacenterWriteResponseHandler.java (+98/-0)
src/java/org/apache/cassandra/service/DigestMismatchException.java (+12/-4)
src/java/org/apache/cassandra/service/EmbeddedCassandraService.java (+5/-24)
src/java/org/apache/cassandra/service/GCInspector.java (+38/-60)
src/java/org/apache/cassandra/service/IResponseResolver.java (+11/-5)
src/java/org/apache/cassandra/service/IWriteResponseHandler.java (+32/-0)
src/java/org/apache/cassandra/service/IndexScanVerbHandler.java (+54/-0)
src/java/org/apache/cassandra/service/LoadDisseminator.java (+0/-39)
src/java/org/apache/cassandra/service/MigrationManager.java (+220/-0)
src/java/org/apache/cassandra/service/QuorumResponseHandler.java (+0/-98)
src/java/org/apache/cassandra/service/RangeSliceResponseResolver.java (+36/-15)
src/java/org/apache/cassandra/service/RangeSliceVerbHandler.java (+17/-10)
src/java/org/apache/cassandra/service/ReadCallback.java (+124/-0)
src/java/org/apache/cassandra/service/ReadResponseResolver.java (+109/-79)
src/java/org/apache/cassandra/service/RepairCallback.java (+74/-0)
src/java/org/apache/cassandra/service/StorageLoadBalancer.java (+38/-68)
src/java/org/apache/cassandra/service/StorageProxy.java (+641/-415)
src/java/org/apache/cassandra/service/StorageProxyMBean.java (+8/-0)
src/java/org/apache/cassandra/service/StorageService.java (+1142/-585)
src/java/org/apache/cassandra/service/StorageServiceMBean.java (+139/-28)
src/java/org/apache/cassandra/service/TruncateResponseHandler.java (+76/-0)
src/java/org/apache/cassandra/service/WriteResponseHandler.java (+97/-81)
src/java/org/apache/cassandra/streaming/CompletedFileStatus.java (+0/-121)
src/java/org/apache/cassandra/streaming/FileStreamTask.java (+156/-0)
src/java/org/apache/cassandra/streaming/IStreamComplete.java (+0/-32)
src/java/org/apache/cassandra/streaming/IncomingStreamReader.java (+56/-51)
src/java/org/apache/cassandra/streaming/PendingFile.java (+75/-63)
src/java/org/apache/cassandra/streaming/ReplicationFinishedVerbHandler.java (+44/-0)
src/java/org/apache/cassandra/streaming/StreamCompletionHandler.java (+0/-83)
src/java/org/apache/cassandra/streaming/StreamFinishedVerbHandler.java (+0/-69)
src/java/org/apache/cassandra/streaming/StreamHeader.java (+102/-0)
src/java/org/apache/cassandra/streaming/StreamIn.java (+37/-7)
src/java/org/apache/cassandra/streaming/StreamInManager.java (+0/-130)
src/java/org/apache/cassandra/streaming/StreamInSession.java (+211/-0)
src/java/org/apache/cassandra/streaming/StreamInitiateDoneVerbHandler.java (+0/-40)
src/java/org/apache/cassandra/streaming/StreamInitiateMessage.java (+0/-92)
src/java/org/apache/cassandra/streaming/StreamInitiateVerbHandler.java (+0/-174)
src/java/org/apache/cassandra/streaming/StreamOut.java (+132/-101)
src/java/org/apache/cassandra/streaming/StreamOutManager.java (+0/-176)
src/java/org/apache/cassandra/streaming/StreamOutSession.java (+178/-0)
src/java/org/apache/cassandra/streaming/StreamReply.java (+91/-0)
src/java/org/apache/cassandra/streaming/StreamReplyVerbHandler.java (+73/-0)
src/java/org/apache/cassandra/streaming/StreamRequestMessage.java (+120/-48)
src/java/org/apache/cassandra/streaming/StreamRequestMetadata.java (+0/-108)
src/java/org/apache/cassandra/streaming/StreamRequestVerbHandler.java (+20/-22)
src/java/org/apache/cassandra/streaming/StreamingService.java (+22/-23)
src/java/org/apache/cassandra/thrift/CassandraDaemon.java (+120/-208)
src/java/org/apache/cassandra/thrift/CassandraServer.java (+591/-348)
src/java/org/apache/cassandra/thrift/CustomTThreadPoolServer.java (+11/-7)
src/java/org/apache/cassandra/thrift/TBinaryProtocol.java (+99/-0)
src/java/org/apache/cassandra/thrift/TCustomServerSocket.java (+106/-0)
src/java/org/apache/cassandra/thrift/ThriftGlue.java (+0/-70)
src/java/org/apache/cassandra/thrift/ThriftValidation.java (+154/-46)
src/java/org/apache/cassandra/tools/ClusterCmd.java (+43/-56)
src/java/org/apache/cassandra/tools/NodeCmd.java (+390/-284)
src/java/org/apache/cassandra/tools/NodeProbe.java (+221/-127)
src/java/org/apache/cassandra/tools/SSTableExport.java (+275/-201)
src/java/org/apache/cassandra/tools/SSTableImport.java (+340/-97)
src/java/org/apache/cassandra/tools/SchemaTool.java (+61/-0)
src/java/org/apache/cassandra/utils/AbstractStatsDeque.java (+0/-1)
src/java/org/apache/cassandra/utils/BitSetSerializer.java (+0/-51)
src/java/org/apache/cassandra/utils/BloomCalculations.java (+18/-0)
src/java/org/apache/cassandra/utils/BloomFilter.java (+89/-149)
src/java/org/apache/cassandra/utils/BloomFilterSerializer.java (+57/-0)
src/java/org/apache/cassandra/utils/ByteBufferUtil.java (+407/-0)
src/java/org/apache/cassandra/utils/CLibrary.java (+93/-0)
src/java/org/apache/cassandra/utils/DefaultDouble.java (+47/-0)
src/java/org/apache/cassandra/utils/DefaultInteger.java (+47/-0)
src/java/org/apache/cassandra/utils/EstimatedHistogram.java (+121/-14)
src/java/org/apache/cassandra/utils/ExpiringMap.java (+62/-100)
src/java/org/apache/cassandra/utils/FBUtilities.java (+230/-208)
src/java/org/apache/cassandra/utils/Filter.java (+5/-71)
src/java/org/apache/cassandra/utils/GuidGenerator.java (+32/-20)
src/java/org/apache/cassandra/utils/LatencyTracker.java (+0/-1)
src/java/org/apache/cassandra/utils/LegacyBloomFilter.java (+176/-0)
src/java/org/apache/cassandra/utils/LegacyBloomFilterSerializer.java (+57/-0)
src/java/org/apache/cassandra/utils/MerkleTree.java (+6/-4)
src/java/org/apache/cassandra/utils/MurmurHash.java (+119/-52)
src/java/org/apache/cassandra/utils/Mx4jTool.java (+96/-0)
src/java/org/apache/cassandra/utils/ResourceWatcher.java (+71/-0)
src/java/org/apache/cassandra/utils/SafeMessageDigest.java (+0/-82)
src/java/org/apache/cassandra/utils/SimpleCondition.java (+2/-2)
src/java/org/apache/cassandra/utils/SkipNullRepresenter.java (+41/-0)
src/java/org/apache/cassandra/utils/StatusLogger.java (+96/-0)
src/java/org/apache/cassandra/utils/UUIDGen.java (+75/-0)
src/java/org/apache/cassandra/utils/XMLUtils.java (+13/-18)
src/java/org/apache/cassandra/utils/obs/ArrayUtil.java (+41/-0)
src/java/org/apache/cassandra/utils/obs/BitUtil.java (+815/-0)
src/java/org/apache/cassandra/utils/obs/OpenBitSet.java (+818/-0)
test/cassandra.in.sh (+1/-0)
test/conf/access.properties (+29/-0)
test/conf/cassandra-topology.properties (+45/-0)
test/conf/cassandra.yaml (+187/-0)
test/conf/datacenters.properties (+26/-0)
test/conf/log4j-server.properties (+25/-0)
test/conf/log4j.properties (+0/-25)
test/conf/storage-conf.xml (+0/-86)
test/data/serialization/0.7/db.migration.Keyspace1.bin (+1/-0)
test/data/serialization/0.7/db.migration.Keyspace2.bin (+1/-0)
test/data/serialization/0.7/db.migration.Keyspace4.bin (+1/-0)
test/data/serialization/0.7/db.migration.Keyspace5.bin (+1/-0)
test/distributed/README.txt (+56/-0)
test/distributed/org/apache/cassandra/CassandraServiceController.java (+333/-0)
test/distributed/org/apache/cassandra/MovementTest.java (+128/-0)
test/distributed/org/apache/cassandra/MutationTest.java (+376/-0)
test/distributed/org/apache/cassandra/TestBase.java (+114/-0)
test/distributed/org/apache/cassandra/utils/BlobUtils.java (+122/-0)
test/distributed/org/apache/cassandra/utils/KeyPair.java (+49/-0)
test/long/org/apache/cassandra/db/LongCompactionSpeedTest.java (+106/-0)
test/long/org/apache/cassandra/db/LongTableTest.java (+85/-0)
test/long/org/apache/cassandra/utils/LongBloomFilterTest.java (+66/-0)
test/long/org/apache/cassandra/utils/LongLegacyBloomFilterTest.java (+66/-0)
test/resources/SimpleCF.json (+2/-2)
test/resources/SuperCF.json (+2/-2)
test/resources/UnsortedSuperCF.json (+5/-0)
test/resources/whirr-default.properties (+21/-0)
test/system/__init__.py (+186/-20)
test/system/avro_utils.py (+37/-0)
test/system/test_avro_meta.py (+66/-0)
test/system/test_avro_standard.py (+394/-0)
test/system/test_avro_super.py (+243/-0)
test/system/test_avro_system.py (+163/-0)
test/system/test_server.py (+0/-1007)
test/system/test_thrift_server.py (+1564/-0)
test/unit/org/apache/cassandra/AbstractSerializationsTester.java (+50/-0)
test/unit/org/apache/cassandra/CleanupHelper.java (+9/-28)
test/unit/org/apache/cassandra/EmbeddedServer.java (+88/-0)
test/unit/org/apache/cassandra/SchemaLoader.java (+48/-0)
test/unit/org/apache/cassandra/Util.java (+70/-21)
test/unit/org/apache/cassandra/auth/SimpleAuthorityTest.java (+84/-0)
test/unit/org/apache/cassandra/cli/CliTest.java (+209/-0)
test/unit/org/apache/cassandra/client/TestRingCache.java (+36/-32)
test/unit/org/apache/cassandra/concurrent/DebuggableThreadPoolExecutorTest.java (+1/-1)
test/unit/org/apache/cassandra/config/ColumnDefinitionTest.java (+55/-0)
test/unit/org/apache/cassandra/config/DatabaseDescriptorTest.java (+100/-0)
test/unit/org/apache/cassandra/db/CleanupTest.java (+146/-0)
test/unit/org/apache/cassandra/db/ColumnFamilyStoreTest.java (+423/-89)
test/unit/org/apache/cassandra/db/ColumnFamilyTest.java (+29/-12)
test/unit/org/apache/cassandra/db/CommitLogTest.java (+122/-45)
test/unit/org/apache/cassandra/db/CompactionsPurgeTest.java (+32/-83)
test/unit/org/apache/cassandra/db/CompactionsTest.java (+71/-9)
test/unit/org/apache/cassandra/db/DefsTest.java (+777/-0)
test/unit/org/apache/cassandra/db/KeyCacheTest.java (+90/-0)
test/unit/org/apache/cassandra/db/MultitableTest.java (+7/-4)
test/unit/org/apache/cassandra/db/NameSortTest.java (+41/-38)
test/unit/org/apache/cassandra/db/OneCompactionTest.java (+8/-6)
test/unit/org/apache/cassandra/db/ReadMessageTest.java (+37/-23)
test/unit/org/apache/cassandra/db/RecoveryManager2Test.java (+10/-9)
test/unit/org/apache/cassandra/db/RecoveryManager3Test.java (+79/-0)
test/unit/org/apache/cassandra/db/RecoveryManagerTest.java (+9/-6)
test/unit/org/apache/cassandra/db/RecoveryManagerTruncateTest.java (+99/-0)
test/unit/org/apache/cassandra/db/RemoveColumnFamilyTest.java (+14/-8)
test/unit/org/apache/cassandra/db/RemoveColumnFamilyWithFlush1Test.java (+15/-9)
test/unit/org/apache/cassandra/db/RemoveColumnFamilyWithFlush2Test.java (+14/-8)
test/unit/org/apache/cassandra/db/RemoveColumnTest.java (+17/-11)
test/unit/org/apache/cassandra/db/RemoveSubColumnTest.java (+14/-10)
test/unit/org/apache/cassandra/db/RemoveSuperColumnTest.java (+64/-54)
test/unit/org/apache/cassandra/db/RowIterationTest.java (+65/-0)
test/unit/org/apache/cassandra/db/RowTest.java (+31/-6)
test/unit/org/apache/cassandra/db/SerializationsTest.java (+336/-0)
test/unit/org/apache/cassandra/db/SuperColumnTest.java (+7/-4)
test/unit/org/apache/cassandra/db/SystemTableTest.java (+0/-48)
test/unit/org/apache/cassandra/db/TableTest.java (+198/-111)
test/unit/org/apache/cassandra/db/TimeSortTest.java (+29/-23)
test/unit/org/apache/cassandra/db/commitlog/CommitLogHeaderTest.java (+50/-0)
test/unit/org/apache/cassandra/db/marshal/IntegerTypeTest.java (+196/-0)
test/unit/org/apache/cassandra/db/marshal/TimeUUIDTypeTest.java (+75/-7)
test/unit/org/apache/cassandra/db/marshal/TypeCompareTest.java (+31/-30)
test/unit/org/apache/cassandra/db/marshal/TypeValidationTest.java (+123/-0)
test/unit/org/apache/cassandra/db/migration/SerializationsTest.java (+80/-0)
test/unit/org/apache/cassandra/dht/BootStrapperTest.java (+88/-16)
test/unit/org/apache/cassandra/dht/ByteOrderedPartitionerTest.java (+32/-0)
test/unit/org/apache/cassandra/dht/CollatingOrderPreservingPartitionerTest.java (+5/-2)
test/unit/org/apache/cassandra/dht/PartitionerTestCase.java (+15/-17)
test/unit/org/apache/cassandra/dht/RangeIntersectionTest.java (+0/-152)
test/unit/org/apache/cassandra/dht/RangeTest.java (+144/-0)
test/unit/org/apache/cassandra/gms/GossipDigestTest.java (+3/-3)
test/unit/org/apache/cassandra/gms/SerializationsTest.java (+115/-0)
test/unit/org/apache/cassandra/hadoop/ColumnFamilyInputFormatTest.java (+7/-9)
test/unit/org/apache/cassandra/io/BloomFilterTrackerTest.java (+1/-0)
test/unit/org/apache/cassandra/io/CompactSerializerTest.java (+149/-0)
test/unit/org/apache/cassandra/io/LazilyCompactedRowTest.java (+240/-0)
test/unit/org/apache/cassandra/io/SSTableReaderTest.java (+0/-100)
test/unit/org/apache/cassandra/io/SSTableTest.java (+0/-95)
test/unit/org/apache/cassandra/io/SSTableUtils.java (+0/-107)
test/unit/org/apache/cassandra/io/StreamingTest.java (+0/-62)
test/unit/org/apache/cassandra/io/sstable/LegacySSTableTest.java (+115/-0)
test/unit/org/apache/cassandra/io/sstable/SSTableReaderTest.java (+151/-0)
test/unit/org/apache/cassandra/io/sstable/SSTableTest.java (+94/-0)
test/unit/org/apache/cassandra/io/sstable/SSTableUtils.java (+163/-0)
test/unit/org/apache/cassandra/io/sstable/SSTableWriterTest.java (+98/-0)
test/unit/org/apache/cassandra/io/util/BufferedRandomAccessFileTest.java (+101/-4)
test/unit/org/apache/cassandra/locator/DynamicEndpointSnitchTest.java (+7/-3)
test/unit/org/apache/cassandra/locator/NetworkTopologyStrategyTest.java (+89/-0)
test/unit/org/apache/cassandra/locator/OldNetworkTopologyStrategyTest.java (+164/-0)
test/unit/org/apache/cassandra/locator/RackUnawareStrategyTest.java (+0/-174)
test/unit/org/apache/cassandra/locator/ReplicationStrategyEndpointCacheTest.java (+174/-0)
test/unit/org/apache/cassandra/locator/SimpleStrategyTest.java (+186/-0)
test/unit/org/apache/cassandra/locator/TokenMetadataTest.java (+1/-1)
test/unit/org/apache/cassandra/service/AntiEntropyServiceTest.java (+79/-91)
test/unit/org/apache/cassandra/service/ConsistencyLevelTest.java (+167/-0)
test/unit/org/apache/cassandra/service/EmbeddedCassandraServiceTest.java (+33/-42)
test/unit/org/apache/cassandra/service/InitClientTest.java (+35/-0)
test/unit/org/apache/cassandra/service/MoveTest.java (+239/-270)
test/unit/org/apache/cassandra/service/RangeSliceResponseResolverTest.java (+0/-74)
test/unit/org/apache/cassandra/service/ReadResponseResolverTest.java (+2/-1)
test/unit/org/apache/cassandra/service/RemoveTest.java (+229/-0)
test/unit/org/apache/cassandra/service/SerializationsTest.java (+101/-0)
test/unit/org/apache/cassandra/service/StorageProxyTest.java (+6/-2)
test/unit/org/apache/cassandra/service/StorageServiceClientTest.java (+2/-1)
test/unit/org/apache/cassandra/streaming/BootstrapTest.java (+18/-24)
test/unit/org/apache/cassandra/streaming/SerializationsTest.java (+204/-0)
test/unit/org/apache/cassandra/streaming/StreamUtil.java (+54/-0)
test/unit/org/apache/cassandra/streaming/StreamingTransferTest.java (+158/-0)
test/unit/org/apache/cassandra/tools/SSTableExportTest.java (+76/-85)
test/unit/org/apache/cassandra/tools/SSTableImportTest.java (+53/-17)
test/unit/org/apache/cassandra/utils/BloomFilterTest.java (+60/-46)
test/unit/org/apache/cassandra/utils/EstimatedHistogramTest.java (+12/-9)
test/unit/org/apache/cassandra/utils/FBUtilitiesTest.java (+41/-2)
test/unit/org/apache/cassandra/utils/FilterTest.java (+0/-114)
test/unit/org/apache/cassandra/utils/FilterTestHelper.java (+82/-0)
test/unit/org/apache/cassandra/utils/KeyGenerator.java (+22/-18)
test/unit/org/apache/cassandra/utils/LegacyBloomFilterTest.java (+138/-0)
test/unit/org/apache/cassandra/utils/MerkleTreeTest.java (+91/-68)
test/unit/org/apache/cassandra/utils/SerializationsTest.java (+117/-0)
test/unit/org/apache/cassandra/utils/UUIDTests.java (+78/-0)
Revision history for this message
Robert Collins (lifeless) wrote :

(I've filed this here because Clint is preparing to upload this to Ubuntu itself and needs to know its already got bugs:)

Revision history for this message
Robert Collins (lifeless) wrote :

possibly related:

 INFO [FlushWriter:1] 2011-02-26 22:26:59,432 Memtable.java (line 155) Writing Memtable-Schema@431432310(2346 bytes, 5 operations)
ERROR [FlushWriter:1] 2011-02-26 22:26:59,433 AbstractCassandraDaemon.java (line 91) Fatal exception in thread Thread[FlushWriter:1,5,main]
java.lang.RuntimeException: java.io.FileNotFoundException: /var/lib/cassandra/data/system/Schema-tmp-e-61-Index.db (Too many open files)
        at org.apache.cassandra.utils.WrappedRunnable.run(WrappedRunnable.java:34)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:471)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
        at java.util.concurrent.FutureTask.run(FutureTask.java:166)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
        at java.lang.Thread.run(Thread.java:636)
Caused by: java.io.FileNotFoundException: /var/lib/cassandra/data/system/Schema-tmp-e-61-Index.db (Too many open files)

Fabio Marconi (fabiomarconi)
affects: ubuntu → apache (Ubuntu)
Clint Byrum (clint-fewbar)
Changed in apache (Ubuntu):
status: New → Incomplete
status: Incomplete → Invalid
Revision history for this message
Clint Byrum (clint-fewbar) wrote :

This is due to depending on libcommons-collections-java instead of libcommons-collections3-java

Fixing and pushing now.

Changed in cassandra-packages:
status: New → In Progress
importance: Undecided → Critical
assignee: nobody → Clint Byrum (clint-fewbar)
Revision history for this message
Clint Byrum (clint-fewbar) wrote :

Robert can you try the version in the PPA now? Thanks!

Revision history for this message
Robert Collins (lifeless) wrote : Re: [Bug 725470] Re: cassandra - crash in compaction using lucid ppa package

This specific error is gone, and a new one is here. This may be data
driven (I haven't deleted my cluster - in a rush this morning, will
fiddle this arvo for you).

 INFO [CompactionExecutor:1] 2011-03-02 05:28:28,582
CompactionManager.java (line 458) Compacted to
/var/lib/cassandra/data/system/Schema-tmp-f-244-Data.db. 600,198 to
599,871 (~99% of original) bytes for 220 keys. Time: 225ms.
ERROR [MigrationStage:1] 2011-03-02 05:28:28,589
AbstractCassandraDaemon.java (line 114) Fatal exception in thread
Thread[MigrationStage:1,5,main]
org.apache.cassandra.config.ConfigurationException: Previous version
mismatch. cannot apply.
        at org.apache.cassandra.db.migration.Migration.apply(Migration.java:115)
        at org.apache.cassandra.thrift.CassandraServer$2.call(CassandraServer.java:633)
        at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
        at java.util.concurrent.FutureTask.run(FutureTask.java:166)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
        at java.lang.Thread.run(Thread.java:636)
 INFO [MigrationStage:1] 2011-03-02 05:28:28,595
ColumnFamilyStore.java (line 665) switching in a fresh Memtable for
OOPS at CommitLogContext(file='/var/lib/cassandra/commitlog/CommitLog-1299004019135.log',
position=634361)

Revision history for this message
Clint Byrum (clint-fewbar) wrote :

On Tue, 2011-03-01 at 18:27 +0000, Robert Collins wrote:
> This specific error is gone, and a new one is here. This may be data
> driven (I haven't deleted my cluster - in a rush this morning, will
> fiddle this arvo for you).
>
> INFO [CompactionExecutor:1] 2011-03-02 05:28:28,582
> CompactionManager.java (line 458) Compacted to
> /var/lib/cassandra/data/system/Schema-tmp-f-244-Data.db. 600,198 to
> 599,871 (~99% of original) bytes for 220 keys. Time: 225ms.
> ERROR [MigrationStage:1] 2011-03-02 05:28:28,589
> AbstractCassandraDaemon.java (line 114) Fatal exception in thread
> Thread[MigrationStage:1,5,main]
> org.apache.cassandra.config.ConfigurationException: Previous version
> mismatch. cannot apply.
> at org.apache.cassandra.db.migration.Migration.apply(Migration.java:115)
> at org.apache.cassandra.thrift.CassandraServer$2.call(CassandraServer.java:633)
> at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:334)
> at java.util.concurrent.FutureTask.run(FutureTask.java:166)
> at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
> at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
> at java.lang.Thread.run(Thread.java:636)
> INFO [MigrationStage:1] 2011-03-02 05:28:28,595
> ColumnFamilyStore.java (line 665) switching in a fresh Memtable for
> OOPS at CommitLogContext(file='/var/lib/cassandra/commitlog/CommitLog-1299004019135.log',
> position=634361)

There was something wrong with 0.7.0 thru 0.7.3 .. I've uploaded 0.7.3
just now to the stable PPA. Once it is available, can you try installing
it and running

nodetool scrub

Which should fix on-disk problems created by those versions. The bug
report mentions IOExceptions, which I don't see above, but it
specifically references compaction as the root of this problem, so it
would appear related.

https://issues.apache.org/jira/browse/CASSANDRA-2217

Clint Byrum (clint-fewbar)
Changed in cassandra-packages:
status: In Progress → Won't Fix
To post a comment you must log in.
This report contains Public information  
Everyone can see this information.
Subscribing...

Other bug subscribers

Remote bug watches

Bug watches keep track of this bug in other bug trackers.