This is an automated email from the ASF dual-hosted git repository. maedhroz pushed a change to branch cep-15-accord in repository https://gitbox.apache.org/repos/asf/cassandra.git
omit 58bc444d05 Accord: NPE in RangeDeps.forEach omit c876f6a01d Prohibit counter column access in Accord transactions omit d8174c7105 CEP-15 (C*) Integrate accord with repair omit a5b8c06bb9 When jvm-dtest is shutting down an instance TCM retries block the shutdown causing the test to fail omit 6d30457aed fix read repair tests omit 9c35158f6a AccordGens.rangeDeps did not enforce unique ranges, which caused tests to fail omit 63f39562ec (Accord) Cassandra bootstrap no longer using the range txn and instead uses the sync point empty txn for reads omit 53aaac0e37 revert async message delivery omit 70a06051be fix ReadCommand.serializedSize omit c42e155518 Accord: PreLoadContext must properly and consistently support ranges omit 548924fdb2 Ninja for CASSANDRA-19305: Disable EphemeralRead by default to get benchmarks stable omit 9ca1e1ac2d Ninja for CASSANDRA-19305: Disable EphemeralRead by default to get benchmarks stable omit d4c308a8a6 perf improvements omit c2ef5f60e7 rebase test fixes omit 303de2ff1d rebase test fixes omit cf69177dfa rebase fixes omit 30ce4ed013 rebase fixes omit 5ab02ad144 rebase - fix cache metrics omit 7bc74f6a5c fix MultiElementType pack/unpack accessor api omit 26e42ecd87 rebase fixes omit 61002437fe CEP-15: (C*) per-table transactional configuration omit e78dde325b Refactor CommandsForKey for efficiency, and to support transitive dependency elision omit 7af41c66a5 Fast single-partition "Ephemeral Reads" omit c2d4e7c4ac Add TODO for TxnQuery using wrong cluster metadata omit 5c72a68e94 dtest Instance shutdown (again) omit 92705d3785 Fix simulator logging and clean shutdown omit 4b75f582cb Fix (de)serialization of WaitingOn into cache omit 924963d558 Get simulator working (again) omit 79a47a6fcb Fix SerializerSupport.reconstruct, and introduce RangeFactory omit 4f6868d38f CASSANDRA-18365: Protocol fixes omit afc58d771f Fix LocalPartitioner duplication in *_for_key Accord system tables omit 31797823a2 fix fast path test epoch wait omit c08d077b98 load both key command histories for operations specifying keyhistory ALL omit 5948dfa972 fix fast path update deadlock omit 5fe0553c38 don't mark initialized cfk instances as updated omit 0d0ffe3801 apply cfk update to both cfk caches omit 2dc4e4462a don't make noise when fast path reconfigs are rejected omit fc12115549 improve accord error logging omit 4c71211235 fix ReducingRangeMapSerializer omit 2776d34714 retry on Invalidated omit 287fd50d53 fix fast path coordinator test omit 07debc22a1 Pre-requisite changes for CASSANDRA-18888 omit 1b5fd65443 Ninja: Added check that command.route is not null when SPL is trying to inform, saw this event in CI and need more details to know what happened omit d2c749321b (Accord): Bug fixes from CASSANDRA-18675 to better support adding keyspaces omit ec992c628e Quick fix for AccordAddTableTest: make rejections catch up omit 40142c9579 (Accord) NPE while trying to serialize FoundKnownMap as value is null half the time but unexpected while serializing omit 87142f8fff Schema based accord fast path configuration omit eeb23fd9ba Fix TombstoneCountWarningTest omit 27aee2edea Don't use ImmediateExectuor in JVM dtests to process messages omit 9e6fbabb97 Fix GuardrailTablesTest omit f66015d409 Instance.receiveMessage should use sync omit 57a803352e Fix StorageAttachedIndexDDLTest failing due to background Accord compactions omit cff60679c9 Add back enforceInvariants=false to shouldCleanup in AccordCommandsPurger omit 0a9dc2cb44 Fix CompactionAccordIteratorsTest omit 8b16431a06 Fix empty row check in command/tfk mutation methods omit 198b719094 Fix AccordCommandsPurger universal durability check omit 374546087e Fix 5.1 rebase bugs omit 7d510d2b4b Fix Mutation serializer omit 55c3a90b11 Fix AccordJournal.Type interop entries omit 3ff08878b6 Fix additional live migration/interop merge issues omit 9866b0f567 Reduce command deps omit 2f6b60aeb8 Ninja for CASSANDRA-19045: use the latest sha from trunk rather than an old one from 10 months ago omit 3fce9c8cda Ninja for CASSANDRA-19045: make sure to use https rather than git@ for submodule so its portable omit 288b744e3b Improve validation and address various discovered faults omit 5b15247947 Quick fix for AccordCommandStoreTest#commandLoadSave() omit ce00bdc6cf Fix Paxos V2 prepare response serialization omit 79b1873da4 Ninja fix SlowMessageFuzzTest and InvertedIndexSearcherTest omit 9839a4021f Accord/non-Accord interoperability omit 657596da2f Accord support for live migration omit 96e33a3774 Several simulator fixes not yet merged to cep-15-accord omit 28fb0d43f2 Use pinned Harry version omit 79cc2061c0 CEP-15: (C*) Implement TopologySorter to prioritise hosts based on DynamicSnitch and/or topology layout omit 135d7bef13 CEP-15: Add Accord configuration stub omit 4599954bc0 CEP-15: Accord metrics omit c4cb6cffc4 Fix Propagate serializer omit ac14ff81b2 Fix AccordJournalTest and ConfigCompatibilityTest, and revert the sendMessageWithFailureCB() callback to printing just the repair failure reason in its error message omit b8dc70f26c ninja-fix: exclude accord_demo.txt from rat checks omit 3374507c1a ninja-fix: minor post-TCM-rebase cleanup omit 0463bfed88 ninja-fix: checkstyle fixes in VirtualTableTest, HistoryValidatorTest, SeedDefiner, RunStartDefiner, and Config omit 36169b53cc CEP-15: Minimize transaction state kept in system tables omit 8da061ca6a - Avoid persisting fragments that do not require completion as Updates in TxnWrite, as they can simply be pulled from PartialTxn when needed in Write#apply() - Avoid serializing full TxnData instances to Accord state tables omit db2bbe7e1a CEP-15: (C*) accord.messages.BeginRecovery.RecoverNack#supersededBy is nullable but C* serializer doesn't expect null omit d4fbb74a40 CEP-15: (C*) NPE on restart as epoch isnt known but verb handler doesnt delay mapping to Node.Id omit b6e0fd6d3d Fix Accord compaction purger tombstone logic omit b1441caaeb Bootstrap/TCM integration test fixes omit f5edfc758e Fix CompactionAccordIteratorsTest omit 9b5673e9d2 CEP-15 (C*): when loading commands that have empty waiting_on, make sure not to loose the partial deps (#3590) omit bbce80147c Allow exceptions to be propagated remotely omit ccc35996a7 CASSANDRA-18774: Fix pre-commit hook omit 866b813ce9 CEP-15 (C*) When a host replacement happens don't loose the peer mapping right away (#3575) omit 59ed5dc356 Support state eviction (i.e. permit the state machine to erase transactions that are known to be applied across the cluster) omit e2748939a5 CEP-15: Accord Bootstrap Integration omit ed51b34987 CEP-15: Convert AccordStateCache cache from write-through to write-back omit f9b0b29149 CEP-15: Extend Accord MessageType with a side effect flag omit f7584fe06e CEP-15: (C*) Add notion of CommandsForRanges and make this durable in C* omit 16031c25a2 make sure workspace.xml specifies a storagedir omit 1be2d91289 removing unnecessary calls to ServerTestUtils.daemonInitialization() in a handful of tests omit 0675d61a1a minor cleanup in Verb and BTreeSet omit db90358abd (Accord only) Permit nodes to join a cluster without the full transaction history omit 13dbbdfa55 CEP-15: Store PreAccept, Accept, Commit, and Apply messages in a durable log before processing by CommandStores omit e10ed43523 CEP-15: (C*) Enhance in-memory FileSystem to work with mmap and support tests to add custom logic omit 00afcc3689 CEP-15: (C*) Accord message processing should avoid being passed on to a Stage and run directly in the messageing handler omit e4a368bd70 CEP-15 (Accord) Original and recover coordinators may hit a race condition with PreApply where reads and writes are interleaved, causing one of the coordinators to see the writes from the other omit e1e90c1a08 CEP-15 (Accord) Expected reply message with verb ACCORD_INFORM_OF_TXNID_RSP but got ACCORD_SIMPLE_RSP omit 7663eaeede Operations.migrateReadRequiredOperations fails due to concurrent access when TransactionStatement is prepared omit 87de7f501f fixing remaining (mostly compilation) issues after initial rebase of cep-15-accord on cep-21-tcm omit cdeb116913 Improve transaction statement validation omit e44a844e2c CEP-15: (Accord) Migrate Accord away from JDK random to a new interface RandomSource omit 743d81a78c Remove git hook for pre-push as it is redundant and causes issues when merging to mainline omit ba4a38f453 CEP-15/Accord Immutable State Refactor omit d57e2e0fb1 add AsyncChain implementations and tests omit 9309960d8a Add support for prepared statements for accord transactions omit 14e5c18489 Fix statement validation against partition range queries omit 63631bad2d Switched away from https endpoints for git submodules in favor of relative paths during development omit d24f0b6291 CEP-15: (C*) Add git submodule for Accord omit 6894205af6 Fix null value handling for static columns omit 6961dfd0cf Switch Node.Id from long to int omit e715f174f9 use equals() rather than reference equality for excluding ourselves from the dependency builder omit 47cb6a5722 Ninja: CASSANDRA-18214 added rat checks to Accord, but our metadata files .BRANCH and .REPO do not have a license, causing the build to fail; exclude rat when building accord omit ca978a9957 Feature Flag for Accord Transactions omit f2c1fdcf22 Introduce Range transactions omit 080903b085 Introduce RangeDeps omit 676af963b9 Post-rebase fixes around CASSANDRA-18099 and CASSANDRA-18114 (among other things) omit c5496e1a57 CASSANDRA-18154: CEP-15: Enhance returning SELECT to allow partition and clustering IN clauses to return multiple partitions/rows omit bb2ee42670 Support CAS and serial read on Accord omit 0b419f6363 Refactor Timestamp/TxnId - Combine real and logical into a single 64-but HLC - Introduce 16 flag bits - Pack epoch (48-bits), HLC (64-bits) and flags (16-bits) into two longs in memory omit 00d0f41a57 Shard local CommandStores on contiguous ranges omit 5ffa9f9bab CEP-15: (C*) Enhance returning SELECT to allow partition and clustering IN clauses to return multiple partitions/rows omit e8775fe122 ninja: pick a cassandra-accord SHA to build against to decouple source trees omit 20a6688913 CEP-15: Multi-Partition Transaction CQL Support (Alpha) omit a40f5e45bf CEP-15: Routables - Integrate accord-core changes for CASSANDRA-18087 omit 5c8eabfe79 Invalidation fixes/improvements - Integrate accord-core changes for CASSANDRA-18057 omit 7aeca7d195 Refactor response tracking to improve efficiency and clarity; introduce dedicated property tests; re-activate fast-path during range movements omit dd142d0d7d Transaction Expiration omit 5e41ee1011 Partial Replication of Transaction State omit 2e30f7e928 Command table now uses a local version added to the payload rather than rely on a version column, and fixed a few feedback related issues omit ff40219827 CEP-15 (C*): Messaging and storage engine integration add ca0b77d743 Repair fuzz tests fail with paxos_variant: v2 add c9625e0102 Merge branch 'cassandra-5.0' into trunk add 46bf9bcace Add properties for redirecting build-resolve to mirrors add e276173d37 Merge branch 'cassandra-3.0' into cassandra-3.11 add c73683c1a8 Merge branch 'cassandra-3.11' into cassandra-4.0 add 59789544bd Merge branch 'cassandra-4.0' into cassandra-4.1 add 7e239c1348 Merge branch 'cassandra-4.1' into cassandra-5.0 add aec7ba04b5 Merge branch 'cassandra-5.0' into trunk add 154ef814bd Ensured that PropertyFileSnitchTest do not overwrite cassandra-toploogy.properties add 2e7def7626 Expose all dropwizard metrics in virtual tables add be507c6e99 Warn clients about possible consistency violations for filtering queries against multiple mutable columns add b37f47b3ee Merge branch 'cassandra-5.0' into trunk add 338e4ed618 Docs: deprecate the usage of apt-key and adopt distribution name add f0aa6744d2 Merge branch 'cassandra-3.11' into cassandra-4.0 add 7cbf59e9a1 Merge branch 'cassandra-4.0' into cassandra-4.1 add 973aad7b68 Merge branch 'cassandra-4.1' into cassandra-5.0 add 2944d77aac Merge branch 'cassandra-5.0' into trunk add b0150e86fb Clean up KeyRangeIterator classes * replace KeyRangeConcatIterator's PriorityQeueu with List * remove KeyRangeIterator.current and simplify * remove injected exception and tests - not relevant to the current implementation * expand randomized testing * inline getCurrent() -> peek(); rename getCount to getMaxKeys * redefine skipTo contract to not return a value (which saves unnecessary work when skipTo is called multiple times in a row) * calling hasNext in skipTo is a [...] add a1b0a310ed Merge branch 'cassandra-5.0' into trunk add f7c11bdcd4 Standalone Jenkinsfile add 2108f9dcaf Merge branch 'cassandra-5.0' into trunk add 6a640b0c4e Change logging to TRACE when failing to get peer certificates add 659e41db9a Merge branch 'cassandra-4.0' into cassandra-4.1 add 00dccf25ab Merge branch 'cassandra-4.1' into cassandra-5.0 add 310d790ce4 Merge branch 'cassandra-5.0' into trunk add 5fb562d7ef Fix hints delivery for a node going down repeatedly add 9752ceb439 Merge branch 'cassandra-4.1' into cassandra-5.0 add da8ab7e20a Merge branch 'cassandra-5.0' into trunk add 6b48f8a11d Harry model that supports value overrides: an ability to provide specific values for clustering, regular, and static columns add 7623e4678b The result of applying a metadata snapshot via ForceSnapshot should return the correct set of modified keys add 0974a3656d Optionally avoid hint transfer during decommission add 39bd3c2261 Merge branch 'cassandra-4.0' into cassandra-4.1 add 7c29439cef Merge branch 'cassandra-4.1' into cassandra-5.0 add cddfd7f17a Merge branch 'cassandra-5.0' into trunk add 5b23692a90 Enrich system_views.pending_hints vtable with hints sizes add cada1a13c8 Vector search should be able to restrict on clustering keys when filtering isn't required add c156258553 Merge branch 'cassandra-5.0' into trunk add 728b9ec4c6 Revisit metadata log schema to remove period field add ccb83d0b6b Prepare debian changelog for 3.0.30 add 00c45611c9 Prepare debian changelog for 3.0.30 add 296b9cb889 Prepare debian changelog for 3.0.30 add 657e595b78 Prepare debian changelog for 3.0.30 add a766c18481 Merge branch 'cassandra-3.0' into cassandra-3.11 add 9a1d7912ef Merge branch 'cassandra-3.11' into cassandra-4.0 add b3bca0ad6a Merge branch 'cassandra-4.0' into cassandra-4.1 add a620a9df86 Merge branch 'cassandra-4.1' into cassandra-5.0 add 3e4f1e2839 Merge branch 'cassandra-5.0' into trunk add d548396597 Use Transformation.Kind.id in local and distributed log tables add d079952c50 Prepare debian changelog for 3.11.17 add fd46d400b5 Merge branch 'cassandra-3.11' into cassandra-4.0 add b525f5fff4 Merge branch 'cassandra-4.0' into cassandra-4.1 add 42498a14fa Merge branch 'cassandra-4.1' into cassandra-5.0 add 74aa4a12ad Merge branch 'cassandra-5.0' into trunk add 44f472d742 Increment version add 7af7f42f5f Merge branch 'cassandra-3.0' into cassandra-3.11 add 53f07f9610 Merge branch 'cassandra-3.11' into cassandra-4.0 add a6209d0cfc Merge branch 'cassandra-4.0' into cassandra-4.1 add e127ddf7dd Merge branch 'cassandra-4.1' into cassandra-5.0 add 9abd84b8f8 Merge branch 'cassandra-5.0' into trunk add 8d705b31e9 Add new TriggersPolicy configuration to allow operators to disable triggers add 2856a34636 Increment version add 0662094b84 Merge branch 'cassandra-3.11' into cassandra-4.0 add 643d7f1751 Merge branch 'cassandra-4.0' into cassandra-4.1 add 0c34234f67 Merge branch 'cassandra-4.1' into cassandra-5.0 add f194c0772c Merge branch 'cassandra-5.0' into trunk add 1a66347e70 Update in-tree docker versions add f345370f35 Merge branch 'cassandra-5.0' into trunk add 9bfaee91c4 Optionally fail writes when SAI refuses to index a term value exceeding a configured maximum size add c33c8ebab4 Merge branch 'cassandra-5.0' into trunk add f92998190c Fix few types issues and implement types compatibility tests add 445ae1a4b1 Merge branch 'cassandra-4.0' into cassandra-4.1 add 82297b490e Merge branch 'cassandra-4.1' into cassandra-5.0 add d9192745bc Merge branch 'cassandra-5.0' into trunk add 80971709b9 Properly set lastModifiedEpoch on multistep operations add a84f7daf05 Ninja: update CHANGES.txt add cbf4dcb334 Enable EpochAwareDebounce to cancel in flight rpc requests add dabcb17552 Improve handling of transient replicas during range movements add e4f030170f Ninja remove unused import add c5c4cd4e57 Update use of transition plan in PrepareReplace add fba4a85b97 Fix CQL tojson timestamp output on negative timestamp values before Gregorian calendar reform in 1582 add e471a57dc2 Merge branch 'cassandra-4.0' into cassandra-4.1 add 93692a4b17 Merge branch 'cassandra-4.1' into cassandra-5.0 add 607d6d0361 Merge branch 'cassandra-5.0' into trunk add 34d999c47a Optimisations to PlacementForRange, improve lookup on r/w path add 17ecece543 ForceSnapshot transformations should not be persisted in the local log table add b7eafa94f3 Remove leftover period column from system.metadata_snapshots add 9157d98e4c Streaming exception race creates corrupt transaction log files that prevent restart add 858a2b2321 Merge branch 'cassandra-4.0' into cassandra-4.1 add 6559983d6c Merge branch 'cassandra-4.1' into cassandra-5.0 add 3b0b52d0f9 Merge branch 'cassandra-5.0' into trunk add fda12b25d2 ninja: remove unused import in StreamFailedWhileReceivingTest which fails the build add ad3c1ce97c Merge branch 'cassandra-5.0' into trunk add 3c85def5cc Honour parameter defaults between builds in Jenkinsfile add 397568d033 Merge branch 'cassandra-5.0' into trunk add 38512a469c Fix peers v2 system table behaviour when 2 nodes swap their IP Addresses add 8619010cdc Reduce heap usage occupied by the metrics add a6e80317de apply schema if schema digest differs add ae9be29918 Merge branch 'cassandra-4.1' into cassandra-5.0 add 20b4ca44d8 Merge branch 'cassandra-5.0' into trunk add 428fa1f445 Make queries visible to the "system_views.queries" virtual table at the coordinator level add a9da19c311 Merge branch 'cassandra-4.1' into cassandra-5.0 add bbcf92b2c4 Merge branch 'cassandra-5.0' into trunk add c14abb40b2 IR may leak SSTables with pending repair when coming from streaming add 7c79d91b6f Merge branch 'cassandra-4.0' into cassandra-4.1 add 1b1f88e38a Merge branch 'cassandra-4.1' into cassandra-5.0 add dd4e3fa6df Merge branch 'cassandra-5.0' into trunk add 334ca05730 Make nodetool import congruent with the documentation by not relying on the folder structure of the imported SSTable files add 85039aa8c5 Merge branch 'cassandra-4.0' into cassandra-4.1 add d1101eeccc Merge branch 'cassandra-4.1' into cassandra-5.0 add 48f6a31879 Merge branch 'cassandra-5.0' into trunk add 3262847ad7 Install ed from bullseye repo add 7dc067e3ac Merge branch 'cassandra-5.0' into trunk add a6fb3b76fe Prepare debian changelog for 4.0.13 add 5cf8a4cbbb Merge branch 'cassandra-4.0' into cassandra-4.1 add d7aa3c60f9 Merge branch 'cassandra-4.1' into cassandra-5.0 add ba902a7915 Merge branch 'cassandra-5.0' into trunk add 6b13426562 Prepare debian changelog for 4.1.5 add 7402bcb8f7 Merge branch 'cassandra-4.1' into cassandra-5.0 add 668d678d5c Merge branch 'cassandra-5.0' into trunk add e22f67a2f7 Make sure IntersectFilteringQueryTest#shouldNotWarnOrFailOnIndexQuery waits for indexes to be available before making queries add 1d04457a24 Merge branch 'cassandra-5.0' into trunk add 326bf4b3f5 Resolve the oldest hints just from descriptors and current writer if available add 41a4a26651 Merge branch 'cassandra-5.0' into trunk add 51d048a93a Add cluster metadata id to gossip syn messages add 7694d90152 Add nodetool command to unregister LEFT nodes add 4d29a1c75e Merge pre-existing schema with the system defined one during upgrade add 67139d5c33 Raise priority of TCM internode messages during critical operations add a9dbb89419 remove unused import add f12f928dee Bring dirs/ownership/perms in line with Debian package add 103e9cca1a Merge branch 'cassandra-4.0' into cassandra-4.1 add 1902195d99 Merge branch 'cassandra-4.1' into cassandra-5.0 add 505f06a4ae Merge branch 'cassandra-5.0' into trunk add 049160e70a Avoid reading of the same IndexInfo from disk many times for a large partition when ShallowIndexedEntry is used add 68a42b23c4 Merge branch 'cassandra-5.0' into trunk add 534da538d2 Refactor Relation and Restrictions hierachies add 0260774e18 CEP-15 (C*): Messaging and storage engine integration add ec28fc9c30 Command table now uses a local version added to the payload rather than rely on a version column, and fixed a few feedback related issues add c5d4dab2eb Partial Replication of Transaction State add 96fd934063 Transaction Expiration add 360fef1c25 Refactor response tracking to improve efficiency and clarity; introduce dedicated property tests; re-activate fast-path during range movements add 47a592b5bb Invalidation fixes/improvements - Integrate accord-core changes for CASSANDRA-18057 add 07062fb23a CEP-15: Routables - Integrate accord-core changes for CASSANDRA-18087 add b7a281b5ed CEP-15: Multi-Partition Transaction CQL Support (Alpha) add 7607414625 ninja: pick a cassandra-accord SHA to build against to decouple source trees add 7c5b41ade6 CEP-15: (C*) Enhance returning SELECT to allow partition and clustering IN clauses to return multiple partitions/rows add 29c3391293 Shard local CommandStores on contiguous ranges add c65aff8ba1 Refactor Timestamp/TxnId - Combine real and logical into a single 64-but HLC - Introduce 16 flag bits - Pack epoch (48-bits), HLC (64-bits) and flags (16-bits) into two longs in memory add cd5d04f29c Support CAS and serial read on Accord add 373b634c73 CASSANDRA-18154: CEP-15: Enhance returning SELECT to allow partition and clustering IN clauses to return multiple partitions/rows add 326070e7a0 Post-rebase fixes around CASSANDRA-18099 and CASSANDRA-18114 (among other things) add 7eed63cb87 Introduce RangeDeps add 82dd77638c Introduce Range transactions add 27ef74d5a1 Feature Flag for Accord Transactions add 42f063b7ea Ninja: CASSANDRA-18214 added rat checks to Accord, but our metadata files .BRANCH and .REPO do not have a license, causing the build to fail; exclude rat when building accord add fc68784bc0 use equals() rather than reference equality for excluding ourselves from the dependency builder add 626845d791 Switch Node.Id from long to int add f859b8a692 Fix null value handling for static columns add b21e340222 CEP-15: (C*) Add git submodule for Accord add 7dfa20cd14 Switched away from https endpoints for git submodules in favor of relative paths during development add e222b895a3 Fix statement validation against partition range queries add 8daf086e80 Add support for prepared statements for accord transactions add 858e365f07 add AsyncChain implementations and tests add 852a5ef619 CEP-15/Accord Immutable State Refactor add c7f4d3190e Remove git hook for pre-push as it is redundant and causes issues when merging to mainline add 2a3e376395 CEP-15: (Accord) Migrate Accord away from JDK random to a new interface RandomSource add 983bcf9a8f Improve transaction statement validation add 62b806267f fixing remaining (mostly compilation) issues after initial rebase of cep-15-accord on cep-21-tcm add 402babffd3 Operations.migrateReadRequiredOperations fails due to concurrent access when TransactionStatement is prepared add 6d96d41d22 CEP-15 (Accord) Expected reply message with verb ACCORD_INFORM_OF_TXNID_RSP but got ACCORD_SIMPLE_RSP add 80c921571b CEP-15 (Accord) Original and recover coordinators may hit a race condition with PreApply where reads and writes are interleaved, causing one of the coordinators to see the writes from the other add df1c5afba1 CEP-15: (C*) Accord message processing should avoid being passed on to a Stage and run directly in the messageing handler add 3771b60799 CEP-15: (C*) Enhance in-memory FileSystem to work with mmap and support tests to add custom logic add cf79991767 CEP-15: Store PreAccept, Accept, Commit, and Apply messages in a durable log before processing by CommandStores add fa6255e9e2 (Accord only) Permit nodes to join a cluster without the full transaction history add f2ea34e52b minor cleanup in Verb and BTreeSet add bb87b98768 removing unnecessary calls to ServerTestUtils.daemonInitialization() in a handful of tests add c91154ba0b make sure workspace.xml specifies a storagedir add 341dccfbde CEP-15: (C*) Add notion of CommandsForRanges and make this durable in C* add 8123938792 CEP-15: Extend Accord MessageType with a side effect flag add ee01c7ef07 CEP-15: Convert AccordStateCache cache from write-through to write-back add b1e4eb3770 CEP-15: Accord Bootstrap Integration add 33e296b580 Support state eviction (i.e. permit the state machine to erase transactions that are known to be applied across the cluster) add eac53dacf2 CEP-15 (C*) When a host replacement happens don't loose the peer mapping right away (#3575) add 9fe7ba3515 CASSANDRA-18774: Fix pre-commit hook add b87f8d0875 Allow exceptions to be propagated remotely add 0f5a53dfdf CEP-15 (C*): when loading commands that have empty waiting_on, make sure not to loose the partial deps (#3590) add 69e28697e7 Fix CompactionAccordIteratorsTest add 7b4e41fb35 Bootstrap/TCM integration test fixes add 33eaacd992 Fix Accord compaction purger tombstone logic add f6d1c55cc6 CEP-15: (C*) NPE on restart as epoch isnt known but verb handler doesnt delay mapping to Node.Id add 9dc5bd39c7 CEP-15: (C*) accord.messages.BeginRecovery.RecoverNack#supersededBy is nullable but C* serializer doesn't expect null add f2d4ce313d - Avoid persisting fragments that do not require completion as Updates in TxnWrite, as they can simply be pulled from PartialTxn when needed in Write#apply() - Avoid serializing full TxnData instances to Accord state tables add d14f2eb42d CEP-15: Minimize transaction state kept in system tables add fd93b4ba05 ninja-fix: checkstyle fixes in VirtualTableTest, HistoryValidatorTest, SeedDefiner, RunStartDefiner, and Config add dd3804ec64 ninja-fix: minor post-TCM-rebase cleanup add 3f0638709f ninja-fix: exclude accord_demo.txt from rat checks add d4efd8be7e Fix AccordJournalTest and ConfigCompatibilityTest, and revert the sendMessageWithFailureCB() callback to printing just the repair failure reason in its error message add 58bf974771 Fix Propagate serializer add 4eed3029db CEP-15: Accord metrics add 8e64a91926 CEP-15: Add Accord configuration stub add 26af79efdd CEP-15: (C*) Implement TopologySorter to prioritise hosts based on DynamicSnitch and/or topology layout add b402d1c95f Use pinned Harry version add ed76b190ad Several simulator fixes not yet merged to cep-15-accord add 3627f83bd1 Accord support for live migration add 4916c6272d Accord/non-Accord interoperability add 49d0e4b329 Ninja fix SlowMessageFuzzTest and InvertedIndexSearcherTest add 9b3521cf35 Fix Paxos V2 prepare response serialization add 1c205f76a4 Quick fix for AccordCommandStoreTest#commandLoadSave() add f88437c5ef Improve validation and address various discovered faults add a41875cb6f Ninja for CASSANDRA-19045: make sure to use https rather than git@ for submodule so its portable add 144966c55d Ninja for CASSANDRA-19045: use the latest sha from trunk rather than an old one from 10 months ago add 6e9689e33c Reduce command deps add cb6124a648 Fix additional live migration/interop merge issues add 2af3aaf8a6 Fix AccordJournal.Type interop entries add a8c029f408 Fix Mutation serializer add 04e0306067 Fix 5.1 rebase bugs add c204f96728 Fix AccordCommandsPurger universal durability check add 6c84d9b717 Fix empty row check in command/tfk mutation methods add ca637a4c67 Fix CompactionAccordIteratorsTest add 44d40853cc Add back enforceInvariants=false to shouldCleanup in AccordCommandsPurger add a9e9328e55 Fix StorageAttachedIndexDDLTest failing due to background Accord compactions add f0be50a4ea Instance.receiveMessage should use sync add 04b192618d Fix GuardrailTablesTest add 9553777392 Don't use ImmediateExectuor in JVM dtests to process messages add 08a6de64ac Fix TombstoneCountWarningTest add 996c17ce11 Schema based accord fast path configuration add 65e329c130 (Accord) NPE while trying to serialize FoundKnownMap as value is null half the time but unexpected while serializing add b5032fc91d Quick fix for AccordAddTableTest: make rejections catch up add ac47e55cf3 (Accord): Bug fixes from CASSANDRA-18675 to better support adding keyspaces add 3080a7c743 Ninja: Added check that command.route is not null when SPL is trying to inform, saw this event in CI and need more details to know what happened add be984de1fb Pre-requisite changes for CASSANDRA-18888 add 4afc618dca fix fast path coordinator test add 07962b7110 retry on Invalidated add 8b718af040 fix ReducingRangeMapSerializer add 026f441b8b improve accord error logging add 7c88ea3bb7 don't make noise when fast path reconfigs are rejected add 684bf5f271 apply cfk update to both cfk caches add 64b77b131f don't mark initialized cfk instances as updated add 72035cac27 fix fast path update deadlock add 52af2901e6 load both key command histories for operations specifying keyhistory ALL add 7be04e7cea fix fast path test epoch wait add 87109f6173 Fix LocalPartitioner duplication in *_for_key Accord system tables add 9636e87803 CASSANDRA-18365: Protocol fixes add be27b9a2ed Fix SerializerSupport.reconstruct, and introduce RangeFactory add 3762b58f3c Get simulator working (again) add c7af15637b Fix (de)serialization of WaitingOn into cache add 3779522607 Fix simulator logging and clean shutdown add 0b90c806df Add TODO for TxnQuery using wrong cluster metadata add 8a8ab8bc37 Fast single-partition "Ephemeral Reads" add 5a7f7a20ba Refactor CommandsForKey for efficiency, and to support transitive dependency elision add 4b4f34f359 CEP-15: (C*) per-table transactional configuration add 13eb03b01e rebase fixes add 52231bb149 fix MultiElementType pack/unpack accessor api new 21983c7b3c post-trunk rebase fixes new 240a5874c0 perf improvements new 3d93925ed4 Ninja for CASSANDRA-19305: Disable EphemeralRead by default to get benchmarks stable new 613763fc0c Accord: PreLoadContext must properly and consistently support ranges new 35d54cf463 fix ReadCommand.serializedSize new 6a022cdb69 revert async message delivery new ac0e1bf7e8 (Accord) Cassandra bootstrap no longer using the range txn and instead uses the sync point empty txn for reads new 1d1aceabd4 AccordGens.rangeDeps did not enforce unique ranges, which caused tests to fail new ed98b3ca41 fix read repair tests new 90a6f6aaa7 When jvm-dtest is shutting down an instance TCM retries block the shutdown causing the test to fail new 9b308e0a41 CEP-15 (C*) Integrate accord with repair new ea61fcd1f1 Prohibit counter column access in Accord transactions new 87c4bf73dc Accord: NPE in RangeDeps.forEach new e4f9434559 post-rebase fixes, mostly around CASSANDRA-19341 and CASSANDRA-19567 new be1015dcc2 make sure StreamSummarySerializer uses the appropriate IPartitioner during deserialization new 681651a4f0 changing accord submodule branch back to trunk This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (58bc444d05) \ N -- N -- N refs/heads/cep-15-accord (681651a4f0) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. The 16 revisions listed above as "new" are entirely new to this repository and will be described in separate emails. The revisions listed as "add" were already present in the repository and have only been added to this reference. Summary of changes: .build/README.md | 122 +- .build/check-code.sh | 2 +- .build/ci/ci_parser.py | 309 +++ .build/ci/generate-ci-summary.sh | 60 + .../{check-code.sh => ci/generate-test-report.sh} | 17 +- .build/ci/junit_helpers.py | 331 ++++ .build/ci/logging.sh | 124 ++ .build/ci/logging_helper.py | 136 ++ .build/{check-code.sh => ci/precommit_check.sh} | 41 +- .build/{check-code.sh => ci/requirements.txt} | 15 +- .build/docker/_build-debian.sh | 5 +- .build/docker/_build-redhat.sh | 2 +- .build/docker/_docker_init_tests.sh | 1 + .build/docker/_docker_run.sh | 17 +- .build/{check-code.sh => docker/build-jars.sh} | 14 +- .build/docker/bullseye-build.docker | 5 +- .build/docker/centos7-build.docker | 2 +- .build/docker/run-tests.sh | 125 +- .build/docker/ubuntu2004_test.docker | 5 +- .build/run-python-dtests.sh | 21 +- .build/run-tests.sh | 14 +- .gitmodules | 2 +- .jenkins/Jenkinsfile | 1289 ++++++------ CHANGES.txt | 30 + NEWS.txt | 1 + build.xml | 75 +- conf/cassandra.yaml | 18 + conf/cassandra_latest.yaml | 6 + .../cassandra/examples/BASH/add_repo_keys.sh | 2 +- .../cassandra/examples/BASH/get_deb_package.sh | 4 +- .../cassandra/pages/developing/cql/triggers.adoc | 4 + .../pages/managing/operating/metrics.adoc | 10 +- .../pages/managing/operating/virtualtables.adoc | 60 +- .../cassandra/partials/package_versions.adoc | 11 +- pylib/cassandra-cqlsh-tests.sh | 3 +- pylib/cqlshlib/cql3handling.py | 5 +- pylib/cqlshlib/test/test_cqlsh_completion.py | 8 +- redhat/cassandra.spec | 11 +- src/antlr/Parser.g | 28 +- .../apache/cassandra/concurrent/TaskFactory.java | 20 +- .../config/CassandraRelevantProperties.java | 3 - src/java/org/apache/cassandra/config/Config.java | 21 + .../cassandra/config/DatabaseDescriptor.java | 20 +- .../apache/cassandra/config/GuardrailsOptions.java | 113 ++ .../apache/cassandra/cql3/ColumnsExpression.java | 583 ++++++ .../apache/cassandra/cql3/MultiColumnRelation.java | 231 --- src/java/org/apache/cassandra/cql3/Operator.java | 480 ++++- src/java/org/apache/cassandra/cql3/Ordering.java | 7 +- .../org/apache/cassandra/cql3/QueryProcessor.java | 2 +- src/java/org/apache/cassandra/cql3/Relation.java | 288 ++- .../cassandra/cql3/SingleColumnRelation.java | 294 --- .../org/apache/cassandra/cql3/TokenRelation.java | 205 -- .../apache/cassandra/cql3/UntypedResultSet.java | 4 +- .../cassandra/cql3/conditions/ColumnCondition.java | 20 +- .../cql3/functions/ClusterMetadataFcts.java | 57 + .../cassandra/cql3/functions/NativeFunctions.java | 1 + .../restrictions/ClusteringColumnRestrictions.java | 72 +- .../cql3/restrictions/ClusteringElements.java | 473 +++++ .../cassandra/cql3/restrictions/LikePattern.java | 117 ++ .../cql3/restrictions/MergedRestriction.java | 344 ++++ .../cql3/restrictions/MultiColumnRestriction.java | 573 ------ .../restrictions/PartitionKeyRestrictions.java | 345 +++- .../PartitionKeySingleRestrictionSet.java | 165 -- .../cassandra/cql3/restrictions/Restriction.java | 67 +- .../cql3/restrictions/RestrictionSet.java | 299 +-- .../cql3/restrictions/RestrictionSetWrapper.java | 75 +- .../cassandra/cql3/restrictions/Restrictions.java | 59 +- .../cql3/restrictions/SimpleRestriction.java | 375 ++++ .../cql3/restrictions/SingleColumnRestriction.java | 830 -------- .../cql3/restrictions/SingleRestriction.java | 121 +- .../cql3/restrictions/StatementRestrictions.java | 273 +-- .../cassandra/cql3/restrictions/TermSlice.java | 180 -- .../cassandra/cql3/restrictions/TokenFilter.java | 336 ---- .../cql3/restrictions/TokenRestriction.java | 341 ---- .../cassandra/cql3/statements/BatchStatement.java | 2 +- .../cql3/statements/BatchUpdatesCollector.java | 9 +- .../cassandra/cql3/statements/CQL3CasRequest.java | 2 +- .../cql3/statements/ModificationStatement.java | 41 +- .../cassandra/cql3/statements/SelectStatement.java | 87 +- .../statements/SingleTableUpdatesCollector.java | 6 +- .../cassandra/cql3/statements/UpdateStatement.java | 6 +- .../cql3/statements/UpdatesCollector.java | 3 +- .../statements/schema/CreateTriggerStatement.java | 7 +- .../org/apache/cassandra/cql3/terms/InMarker.java | 4 +- .../org/apache/cassandra/cql3/terms/Marker.java | 11 +- src/java/org/apache/cassandra/cql3/terms/Term.java | 25 +- .../org/apache/cassandra/cql3/terms/Terms.java | 96 +- .../org/apache/cassandra/cql3/terms/Tuples.java | 19 - .../org/apache/cassandra/db/ColumnFamilyStore.java | 25 +- src/java/org/apache/cassandra/db/Directories.java | 55 +- src/java/org/apache/cassandra/db/IMutation.java | 27 +- .../org/apache/cassandra/db/MultiCBuilder.java | 535 ++--- .../org/apache/cassandra/db/SSTableImporter.java | 4 +- .../org/apache/cassandra/db/SystemKeyspace.java | 43 +- .../db/compaction/AbstractStrategyHolder.java | 1 + .../db/compaction/CompactionStrategyHolder.java | 6 + .../db/compaction/CompactionStrategyManager.java | 18 +- .../db/compaction/PendingRepairHolder.java | 12 + .../db/compaction/PendingRepairManager.java | 11 +- .../org/apache/cassandra/db/filter/RowFilter.java | 196 +- .../apache/cassandra/db/guardrails/Guardrails.java | 137 +- .../cassandra/db/guardrails/GuardrailsConfig.java | 70 + .../cassandra/db/guardrails/GuardrailsMBean.java | 88 + .../org/apache/cassandra/db/lifecycle/LogFile.java | 36 +- .../cassandra/db/lifecycle/LogReplicaSet.java | 6 +- .../org/apache/cassandra/db/lifecycle/Tracker.java | 2 + .../TransactionAlreadyCompletedException.java} | 21 +- .../db/marshal/AbstractCompositeType.java | 2 +- .../org/apache/cassandra/db/marshal/DateType.java | 2 +- .../apache/cassandra/db/marshal/TimestampType.java | 2 +- .../org/apache/cassandra/db/marshal/TupleType.java | 6 +- .../apache/cassandra/db/marshal/TypeParser.java | 2 +- .../org/apache/cassandra/db/marshal/UserType.java | 2 +- .../org/apache/cassandra/db/memtable/Memtable.java | 23 +- .../apache/cassandra/db/memtable/TrieMemtable.java | 7 +- .../cassandra/db/partitions/PartitionUpdate.java | 5 +- .../cassandra/db/virtual/BatchMetricsTable.java | 14 +- .../cassandra/db/virtual/CQLMetricsTable.java | 11 +- .../db/virtual/ClusterMetadataDirectoryTable.java | 106 + .../db/virtual/ClusterMetadataLogTable.java | 14 +- .../db/virtual/CollectionVirtualTableAdapter.java | 582 ++++++ .../apache/cassandra/db/virtual/PeersTable.java | 26 +- .../cassandra/db/virtual/PendingHintsTable.java | 14 +- .../apache/cassandra/db/virtual/QueriesTable.java | 2 +- .../cassandra/db/virtual/SystemViewsKeyspace.java | 12 +- .../cassandra/db/virtual/ThreadPoolsTable.java | 94 - .../cassandra/db/virtual/VirtualKeyspace.java | 12 + .../cassandra/db/virtual/VirtualMutation.java | 3 +- .../apache/cassandra/db/virtual/model/Column.java | 64 + .../virtual/model/CounterMetricRow.java} | 38 +- .../virtual/model/GaugeMetricRow.java} | 42 +- .../db/virtual/model/HistogramMetricRow.java | 100 + .../cassandra/db/virtual/model/MeterMetricRow.java | 81 + .../virtual/model/MetricGroupRow.java} | 34 +- .../cassandra/db/virtual/model/MetricRow.java | 80 + .../cassandra/db/virtual/model/ThreadPoolRow.java | 94 + .../cassandra/db/virtual/model/TimerMetricRow.java | 81 + .../db/virtual/walker/CounterMetricRowWalker.java | 62 + .../db/virtual/walker/GaugeMetricRowWalker.java | 62 + .../virtual/walker/HistogramMetricRowWalker.java | 76 + .../db/virtual/walker/MeterMetricRowWalker.java | 70 + .../db/virtual/walker/MetricGroupRowWalker.java | 59 + .../db/virtual/walker/MetricRowWalker.java | 64 + .../cassandra/db/virtual/walker/RowWalker.java | 87 + .../db/virtual/walker/ThreadPoolRowWalker.java | 76 + .../db/virtual/walker/TimerMetricRowWalker.java | 70 + .../org/apache/cassandra/dht/IPartitioner.java | 15 - .../dht/IPartitionerDependentSerializer.java | 25 +- .../dht/ReversedLongLocalPartitioner.java | 18 +- src/java/org/apache/cassandra/dht/Token.java | 28 + .../org/apache/cassandra/gms/GossipDigestSyn.java | 15 +- .../cassandra/gms/GossipDigestSynVerbHandler.java | 7 + src/java/org/apache/cassandra/gms/Gossiper.java | 5 + src/java/org/apache/cassandra/gms/IGossiper.java | 3 + src/java/org/apache/cassandra/gms/NewGossiper.java | 6 +- .../org/apache/cassandra/hints/HintsBuffer.java | 38 +- .../apache/cassandra/hints/HintsBufferPool.java | 17 - .../org/apache/cassandra/hints/HintsService.java | 18 +- .../org/apache/cassandra/hints/HintsStore.java | 66 +- .../apache/cassandra/hints/HintsWriteExecutor.java | 52 +- .../apache/cassandra/hints/PendingHintsInfo.java | 24 +- src/java/org/apache/cassandra/index/Index.java | 5 +- .../org/apache/cassandra/index/IndexRegistry.java | 50 +- .../cassandra/index/SecondaryIndexManager.java | 7 +- .../cassandra/index/accord/IndexMetrics.java | 2 +- .../apache/cassandra/index/accord/RouteIndex.java | 3 +- .../cassandra/index/internal/CassandraIndex.java | 10 +- .../cassandra/index/sai/StorageAttachedIndex.java | 89 +- .../index/sai/disk/IndexSearchResultIterator.java | 39 +- .../index/sai/disk/v1/SSTableIndexWriter.java | 2 +- .../disk/v1/postings/PostingListRangeIterator.java | 2 +- .../sai/iterators/KeyRangeConcatIterator.java | 105 +- .../iterators/KeyRangeIntersectionIterator.java | 132 +- .../index/sai/iterators/KeyRangeIterator.java | 99 +- .../sai/iterators/KeyRangeOrderingIterator.java | 2 +- .../index/sai/iterators/KeyRangeUnionIterator.java | 84 +- .../index/sai/memory/InMemoryKeyRangeIterator.java | 4 +- .../index/sai/memory/TrieMemoryIndex.java | 2 +- .../index/sai/memory/VectorMemoryIndex.java | 2 +- .../index/sai/metrics/AbstractMetrics.java | 27 +- .../index/sai/metrics/ColumnQueryMetrics.java | 24 +- .../cassandra/index/sai/plan/QueryController.java | 33 +- .../org/apache/cassandra/index/sasi/SASIIndex.java | 4 +- .../io/IVersionedAsymmetricSerializer.java | 6 +- .../io/sstable/format/big/IndexState.java | 13 +- .../io/sstable/format/big/RowIndexEntry.java | 3 +- src/java/org/apache/cassandra/journal/Metrics.java | 6 +- .../cassandra/locator/CMSPlacementStrategy.java | 12 +- .../cassandra/locator/EndpointsByReplica.java | 16 +- .../apache/cassandra/locator/LocalStrategy.java | 19 +- .../org/apache/cassandra/locator/MetaStrategy.java | 28 +- .../cassandra/locator/NetworkTopologyStrategy.java | 6 +- src/java/org/apache/cassandra/locator/Replica.java | 10 +- .../apache/cassandra/locator/SimpleStrategy.java | 6 +- .../cassandra/metrics/AccordStateCacheMetrics.java | 6 +- .../org/apache/cassandra/metrics/BatchMetrics.java | 4 +- .../cassandra/metrics/BufferPoolMetrics.java | 3 +- .../metrics/CASClientWriteRequestMetrics.java | 4 +- .../cassandra/metrics/CIDRAuthorizerMetrics.java | 3 +- .../org/apache/cassandra/metrics/CQLMetrics.java | 3 +- .../org/apache/cassandra/metrics/CacheMetrics.java | 4 +- .../apache/cassandra/metrics/CacheSizeMetrics.java | 4 +- .../metrics/CassandraMetricsRegistry.java | 473 ++++- .../cassandra/metrics/ChunkCacheMetrics.java | 3 +- .../metrics/ClientMessageSizeMetrics.java | 2 +- .../apache/cassandra/metrics/ClientMetrics.java | 14 +- .../cassandra/metrics/ClientRequestMetrics.java | 3 +- .../metrics/ClientRequestSizeMetrics.java | 2 +- .../apache/cassandra/metrics/CommitLogMetrics.java | 3 +- .../cassandra/metrics/CompactionMetrics.java | 3 +- .../apache/cassandra/metrics/DenylistMetrics.java | 3 +- .../cassandra/metrics/DroppedMessageMetrics.java | 2 +- .../cassandra/metrics/HintedHandoffMetrics.java | 3 +- .../cassandra/metrics/HintsServiceMetrics.java | 3 +- .../cassandra/metrics/InternodeInboundMetrics.java | 3 +- .../metrics/InternodeOutboundMetrics.java | 2 +- .../apache/cassandra/metrics/KeyspaceMetrics.java | 56 +- .../apache/cassandra/metrics/LatencyMetrics.java | 17 +- .../apache/cassandra/metrics/MessagingMetrics.java | 3 +- .../apache/cassandra/metrics/MutualTlsMetrics.java | 3 +- .../org/apache/cassandra/metrics/PaxosMetrics.java | 3 +- .../cassandra/metrics/ReadRepairMetrics.java | 3 +- .../apache/cassandra/metrics/StorageMetrics.java | 1 + .../apache/cassandra/metrics/StreamingMetrics.java | 2 +- .../org/apache/cassandra/metrics/TCMMetrics.java | 3 +- .../org/apache/cassandra/metrics/TableMetrics.java | 154 +- .../cassandra/metrics/ThreadPoolMetrics.java | 7 +- .../cassandra/metrics/TrieMemtableMetricsView.java | 47 +- .../cassandra/metrics/UnweightedCacheMetrics.java | 3 +- src/java/org/apache/cassandra/net/Message.java | 21 +- .../org/apache/cassandra/net/MessageDelivery.java | 5 + src/java/org/apache/cassandra/net/MessageFlag.java | 4 +- .../org/apache/cassandra/net/MessagingService.java | 7 +- .../apache/cassandra/net/OutboundConnections.java | 7 +- src/java/org/apache/cassandra/net/Verb.java | 30 +- .../apache/cassandra/repair/RepairCoordinator.java | 16 + .../org/apache/cassandra/repair/RepairJob.java | 2 +- .../org/apache/cassandra/repair/RepairJobDesc.java | 27 +- .../cassandra/repair/RepairMessageVerbHandler.java | 3 + .../org/apache/cassandra/repair/SharedContext.java | 40 + .../cassandra/repair/messages/PrepareMessage.java | 23 +- .../cassandra/repair/messages/SyncRequest.java | 10 +- .../cassandra/repair/messages/SyncResponse.java | 9 +- .../apache/cassandra/schema/ColumnMetadata.java | 18 +- .../schema/DistributedMetadataLogKeyspace.java | 87 +- .../apache/cassandra/schema/DistributedSchema.java | 39 +- .../org/apache/cassandra/schema/Keyspaces.java | 9 + .../apache/cassandra/schema/SchemaConstants.java | 1 + .../cassandra/serializers/TimestampSerializer.java | 35 +- .../cassandra/service/ActiveRepairService.java | 40 +- .../apache/cassandra/service/CassandraDaemon.java | 8 +- .../cassandra/service/NativeTransportService.java | 1 + .../org/apache/cassandra/service/StorageProxy.java | 6 +- .../apache/cassandra/service/StorageService.java | 38 +- .../org/apache/cassandra/service/paxos/Paxos.java | 75 +- .../cassandra/service/paxos/PaxosCommit.java | 8 +- .../service/paxos/PaxosCommitAndPrepare.java | 4 +- .../cassandra/service/paxos/PaxosPrepare.java | 2 +- .../service/paxos/PaxosPrepareRefresh.java | 2 +- .../cassandra/service/paxos/PaxosPropose.java | 2 +- .../cassandra/service/paxos/PaxosRepair.java | 21 +- .../service/paxos/cleanup/PaxosCleanup.java | 36 +- .../paxos/cleanup/PaxosCleanupComplete.java | 31 +- .../cleanup/PaxosCleanupLocalCoordinator.java | 22 +- .../service/paxos/cleanup/PaxosCleanupRequest.java | 74 +- .../paxos/cleanup/PaxosCleanupResponse.java | 8 +- .../service/paxos/cleanup/PaxosCleanupSession.java | 59 +- .../paxos/cleanup/PaxosFinishPrepareCleanup.java | 112 +- ...shPrepareCleanup.java => PaxosRepairState.java} | 138 +- .../paxos/cleanup/PaxosStartPrepareCleanup.java | 39 +- .../service/paxos/cleanup/PaxosTableRepairs.java | 24 - .../paxos/uncommitted/PaxosUncommittedIndex.java | 4 +- .../paxos/uncommitted/PaxosUncommittedTracker.java | 4 +- .../paxos/uncommitted/UncommittedTableData.java | 34 +- .../service/reads/range/ReplicaPlanIterator.java | 5 +- .../apache/cassandra/streaming/SessionSummary.java | 4 +- .../streaming/StreamDeserializingTask.java | 3 +- .../apache/cassandra/streaming/StreamRequest.java | 20 +- .../apache/cassandra/streaming/StreamSession.java | 20 + .../apache/cassandra/streaming/StreamSummary.java | 20 +- .../streaming/messages/CompleteMessage.java | 3 +- .../streaming/messages/IncomingStreamMessage.java | 3 +- .../streaming/messages/KeepAliveMessage.java | 3 +- .../streaming/messages/OutgoingStreamMessage.java | 3 +- .../streaming/messages/PrepareAckMessage.java | 3 +- .../streaming/messages/PrepareSynAckMessage.java | 5 +- .../streaming/messages/PrepareSynMessage.java | 5 +- .../streaming/messages/ReceivedMessage.java | 3 +- .../streaming/messages/SessionFailedMessage.java | 3 +- .../streaming/messages/StreamInitMessage.java | 3 +- .../streaming/messages/StreamMessage.java | 7 +- .../cassandra/tcm/AbstractLocalProcessor.java | 10 +- .../cassandra/tcm/AtomicLongBackedProcessor.java | 23 +- .../org/apache/cassandra/tcm/CMSOperations.java | 55 +- .../apache/cassandra/tcm/CMSOperationsMBean.java | 4 +- .../org/apache/cassandra/tcm/ClusterMetadata.java | 118 +- .../cassandra/tcm/ClusterMetadataService.java | 21 +- .../apache/cassandra/tcm/EpochAwareDebounce.java | 50 +- .../org/apache/cassandra/tcm/FetchPeerLog.java | 2 +- .../org/apache/cassandra/tcm/MetadataKeys.java | 47 + .../apache/cassandra/tcm/MetadataSnapshots.java | 18 +- .../apache/cassandra/tcm/MultiStepOperation.java | 4 +- .../apache/cassandra/tcm/PaxosBackedProcessor.java | 10 +- .../org/apache/cassandra/tcm/PeerLogFetcher.java | 19 +- .../org/apache/cassandra/tcm/RemoteProcessor.java | 38 +- src/java/org/apache/cassandra/tcm/Startup.java | 15 +- .../cassandra/tcm/StubClusterMetadataService.java | 87 +- .../org/apache/cassandra/tcm/Transformation.java | 5 +- .../cassandra/tcm/compatibility/GossipHelper.java | 7 - .../tcm/listeners/LegacyStateListener.java | 10 +- .../tcm/listeners/MetadataSnapshotListener.java | 13 +- .../org/apache/cassandra/tcm/log/LocalLog.java | 12 +- .../org/apache/cassandra/tcm/log/LogReader.java | 171 +- .../org/apache/cassandra/tcm/log/LogStorage.java | 8 +- .../cassandra/tcm/log/SystemKeyspaceStorage.java | 67 +- .../cassandra/tcm/ownership/DataPlacement.java | 90 +- .../cassandra/tcm/ownership/DataPlacements.java | 41 +- .../cassandra/tcm/ownership/EntireRange.java | 50 - .../cassandra/tcm/ownership/MovementMap.java | 7 +- .../cassandra/tcm/ownership/PlacementDeltas.java | 22 + .../tcm/ownership/PlacementTransitionPlan.java | 89 + .../{PlacementForRange.java => ReplicaGroups.java} | 273 ++- .../tcm/ownership/VersionedEndpoints.java | 6 +- .../tcm/sequences/CancelCMSReconfiguration.java | 6 +- .../org/apache/cassandra/tcm/sequences/Move.java | 25 +- .../cassandra/tcm/sequences/ReconfigureCMS.java | 16 +- .../cassandra/tcm/sequences/RemoveNodeStreams.java | 43 +- .../tcm/sequences/UnbootstrapStreams.java | 25 +- .../PartitionerAwareMetadataSerializer.java | 7 +- .../tcm/transformations/CustomTransformation.java | 44 + .../tcm/transformations/ForceSnapshot.java | 4 +- .../cassandra/tcm/transformations/PrepareJoin.java | 11 +- .../tcm/transformations/PrepareLeave.java | 1 + .../cassandra/tcm/transformations/PrepareMove.java | 7 + .../tcm/transformations/PrepareReplace.java | 32 +- .../cassandra/tcm/transformations/Register.java | 3 +- .../cassandra/tcm/transformations/Startup.java | 2 +- .../{SealPeriod.java => TriggerSnapshot.java} | 38 +- .../cassandra/tcm/transformations/Unregister.java | 50 +- .../cassandra/tcm/transformations/UnsafeJoin.java | 5 + .../cms/AdvanceCMSReconfiguration.java | 12 +- .../cms/BaseMembershipTransformation.java | 4 +- .../tcm/transformations/cms/FinishAddToCMS.java | 6 +- .../tcm/transformations/cms/Initialize.java | 10 +- .../tcm/transformations/cms/PreInitialize.java | 11 +- .../cms/PrepareCMSReconfiguration.java | 2 +- .../tcm/transformations/cms/RemoveFromCMS.java | 6 +- .../tcm/transformations/cms/StartAddToCMS.java | 6 +- src/java/org/apache/cassandra/tools/NodeTool.java | 5 +- .../tools/TransformClusterMetadataHelper.java | 4 +- .../apache/cassandra/tools/nodetool/CMSAdmin.java | 23 + .../cassandra/transport/ServerConnection.java | 3 +- .../TriggerDisabledException.java} | 14 +- .../apache/cassandra/triggers/TriggerExecutor.java | 35 + .../cassandra/utils/AbstractGuavaIterator.java | 5 +- .../apache/cassandra/utils/CassandraVersion.java | 5 + .../apache/cassandra/utils/EstimatedHistogram.java | 6 + .../org/apache/cassandra/utils/FBUtilities.java | 5 +- .../org/apache/cassandra/utils/SystemInfo.java | 15 +- .../cassandra/utils/memory/MemtablePool.java | 4 +- .../cassandra/anttasks/TestNameCheckTask.java | 26 +- test/data/serialization/5.1/gms.Gossip.bin | Bin 166 -> 4914 bytes .../serialization/5.1/service.SyncComplete.bin | Bin 258 -> 346 bytes .../data/serialization/5.1/service.SyncRequest.bin | Bin 111 -> 155 bytes .../5.1/service.ValidationComplete.bin | Bin 597 -> 729 bytes .../5.1/service.ValidationRequest.bin | Bin 74 -> 118 bytes test/data/types-compatibility/4.0.json.gz | Bin 0 -> 397346 bytes test/data/types-compatibility/4.1.json.gz | Bin 0 -> 396407 bytes test/data/types-compatibility/5.0.json.gz | Bin 0 -> 397761 bytes .../cassandra/distributed/impl/Instance.java | 13 + .../cassandra/distributed/shared/ClusterUtils.java | 14 +- .../distributed/test/AbstractHintWindowTest.java | 126 ++ .../distributed/test/DistributedRepairUtils.java | 34 + .../distributed/test/HintsMaxWindowTest.java | 104 + .../test/HintsPersistentWindowTest.java | 99 + .../distributed/test/PaxosRepairTest.java | 7 +- .../distributed/test/QueriesTableTest.java | 221 ++- .../distributed/test/RepairCoordinatorFast.java | 3 + .../test/RepairCoordinatorNeighbourDown.java | 3 + .../test/TransientRangeMovement2Test.java | 59 +- .../test/TransientRangeMovementTest.java | 88 +- .../GuardrailNonPartitionRestrictedQueryTest.java | 37 +- .../test/guardrails/GuardrailTester.java | 41 +- .../guardrails/IntersectFilteringQueryTest.java | 126 ++ .../distributed/test/log/BootWithMetadataTest.java | 6 +- .../test/log/BounceResetHostIdTest.java | 117 +- .../distributed/test/log/CMSCatchupTest.java | 71 + .../distributed/test/log/CMSTestBase.java | 4 +- .../test/log/ClusterMetadataTestHelper.java | 50 +- .../distributed/test/log/CoordinatorPathTest.java | 10 +- .../test/log/CoordinatorPathTestBase.java | 2 +- .../distributed/test/log/DistributedLogTest.java | 5 +- .../test/log/FetchLogFromPeers2Test.java | 134 ++ .../test/log/FetchLogFromPeersTest.java | 147 +- .../test/log/MetadataChangeSimulationTest.java | 135 +- .../distributed/test/log/MetadataKeysTest.java | 220 +++ .../cassandra/distributed/test/log/ModelState.java | 7 +- .../test/log/OperationalEquivalenceTest.java | 55 +- .../distributed/test/log/PlacementSimulator.java | 319 +-- .../test/log/PlacementSimulatorTest.java | 5 +- .../distributed/test/log/ReconfigureCMSTest.java | 14 +- .../distributed/test/log/RegisterTest.java | 12 +- .../distributed/test/log/ReplayPersistedTest.java | 4 +- .../distributed/test/log/SimulatedOperation.java | 4 +- .../distributed/test/log/SnapshotTest.java | 49 +- .../test/log/SystemKeyspaceStorageTest.java | 67 +- .../distributed/test/log/UnregisterTest.java | 100 + .../test/ring/CMSUrgentMessagesTest.java | 74 + .../distributed/test/ring/RangeVersioningTest.java | 4 +- .../streaming/StreamFailedWhileReceivingTest.java | 207 ++ .../test/tcm/RepairMetadataKeyspaceTest.java | 123 ++ .../distributed/test/tcm/SplitBrainTest.java | 161 +- .../fuzz/harry/examples/RepairBurnTest.java | 138 ++ .../dsl/HistoryBuilderIntegrationTest.java | 153 +- .../HistoryBuilderOverridesIntegrationTest.java | 359 ++++ .../integration/model/IntegrationTestBase.java | 12 +- .../model/ReconcilerIntegrationTest.java | 23 +- .../fuzz/ring/ConsistentBootstrapTest.java | 8 +- .../cassandra/fuzz/sai/SingleNodeSAITest.java | 11 +- .../cassandra/fuzz/sai/StaticsTortureTest.java | 20 +- .../cassandra/harry/checker/ModelChecker.java | 1 + .../org/apache/cassandra/harry/ddl/ColumnSpec.java | 44 +- .../org/apache/cassandra/harry/ddl/SchemaSpec.java | 36 +- .../apache/cassandra/harry/dsl/ArrayWrapper.java | 32 +- .../cassandra/harry/dsl/BatchVisitBuilder.java | 11 +- .../apache/cassandra/harry/dsl/HistoryBuilder.java | 141 +- .../cassandra/harry/dsl/OverridingBijection.java | 84 + .../cassandra/harry/dsl/OverridingCkGenerator.java | 153 ++ .../cassandra/harry/dsl/PartitionVisitState.java | 63 +- .../harry/dsl/PartitionVisitStateImpl.java | 115 ++ .../harry/dsl/ReplayingHistoryBuilder.java | 13 +- .../harry/dsl/SingleOperationBuilder.java | 5 +- .../harry/dsl/SingleOperationVisitBuilder.java | 72 +- .../harry/dsl/ValueDescriptorIndexGenerator.java | 13 +- .../apache/cassandra/harry/dsl/ValueHelper.java | 74 + .../apache/cassandra/harry/dsl/ValueOverrides.java | 7 +- .../apache/cassandra/harry/gen/DataGenerators.java | 24 +- .../apache/cassandra/harry/gen/EntropySource.java | 5 +- .../org/apache/cassandra/harry/gen/Generators.java | 42 +- .../apache/cassandra/harry/model/NoOpChecker.java | 16 +- .../model/QuiescentLocalStateCheckerBase.java | 9 +- .../cassandra/harry/operations/Relation.java | 2 +- .../cassandra/harry/sut/TokenPlacementModel.java | 272 ++- .../sut/injvm/InJVMTokenAwareVisitExecutor.java | 8 +- .../test/microbench/ReplicaGroupsBench.java | 138 ++ .../simulator/cluster/KeyspaceActions.java | 12 +- .../simulator/harry/HarryValidatingQuery.java | 8 +- .../CassandraXMLJUnitResultFormatter.java | 24 +- .../config/DatabaseDescriptorRefTest.java | 1 + test/unit/org/apache/cassandra/cql3/CQLTester.java | 104 +- .../org/apache/cassandra/cql3/RelationTest.java | 81 + .../cql3/functions/ClusterMetadataFctsTest.java | 68 + .../ClusteringColumnRestrictionsTest.java | 2068 ++++++++++---------- .../cql3/restrictions/ClusteringElementsTest.java | 676 +++++++ .../validation/entities/FrozenCollectionsTest.java | 3 +- .../cql3/validation/entities/JsonTest.java | 9 + .../entities/SecondaryIndexOnMapEntriesTest.java | 2 +- .../operations/CompactStorageSplit1Test.java | 2 +- .../operations/CompactStorageSplit2Test.java | 184 +- .../InsertInvalidateSizedRecordsTest.java | 10 +- .../operations/SelectMultiColumnRelationTest.java | 30 +- .../operations/SelectOrderedPartitionerTest.java | 24 +- .../operations/SelectSingleColumnRelationTest.java | 30 +- .../cql3/validation/operations/SelectTest.java | 154 +- test/unit/org/apache/cassandra/db/ImportTest.java | 66 +- .../guardrails/GuardrailColumnValueSizeTest.java | 237 +-- .../guardrails/GuardrailSaiFrozenTermSizeTest.java | 139 ++ .../guardrails/GuardrailSaiStringTermSizeTest.java | 215 ++ .../guardrails/GuardrailSaiVectorTermSizeTest.java | 133 ++ .../db/guardrails/ValueThresholdTester.java | 273 +++ .../cassandra/db/lifecycle/LogTransactionTest.java | 40 +- .../cassandra/db/marshal/AbstractTypeTest.java | 922 ++++++++- .../virtual/CollectionVirtualTableAdapterTest.java | 243 +++ .../db/virtual/LocalRepairTablesTest.java | 2 +- .../db/virtual/model/CollectionEntry.java | 126 ++ .../db/virtual/model/CollectionEntryTestRow.java | 93 + .../db/virtual/model/PartitionEntryTestRow.java | 42 +- .../walker/CollectionEntryTestRowWalker.java | 76 + .../walker/PartitionEntryTestRowWalker.java | 62 + .../apache/cassandra/gms/SerializationsTest.java | 7 +- .../apache/cassandra/hints/HintsBufferTest.java | 47 - .../cassandra/hints/HintsPendingTableTest.java | 163 ++ .../apache/cassandra/hints/HintsServiceTest.java | 48 - .../org/apache/cassandra/hints/HintsStoreTest.java | 12 +- .../unit/org/apache/cassandra/index/StubIndex.java | 4 +- .../index/internal/CustomCassandraIndex.java | 4 +- .../index/sai/cql/AllTypesSimpleEqTest.java | 9 +- .../index/sai/cql/CollectionIndexingTest.java | 2 +- .../index/sai/cql/StorageAttachedIndexDDLTest.java | 47 - .../index/sai/cql/UnindexedExpressionsTest.java | 2 +- .../index/sai/cql/VectorInvalidQueryTest.java | 39 + .../index/sai/disk/SingleNodeQueryFailureTest.java | 100 +- .../sai/disk/v1/BalancedTreeIndexSearcherTest.java | 2 - .../sai/disk/v1/InvertedIndexSearcherTest.java | 2 - .../iterators/AbstractKeyRangeIteratorTester.java | 119 +- .../sai/iterators/KeyRangeConcatIteratorTest.java | 83 +- .../KeyRangeIntersectionIteratorTest.java | 127 +- .../sai/iterators/KeyRangeUnionIteratorTest.java | 151 +- .../index/sai/iterators/LongIterator.java | 21 +- .../index/sai/utils/SAIRandomizedTester.java | 10 + .../cassandra/io/sstable/CQLSSTableWriterTest.java | 2 +- .../apache/cassandra/locator/MetaStrategyTest.java | 3 - .../cassandra/locator/PropertyFileSnitchTest.java | 6 +- .../apache/cassandra/metrics/BatchMetricsTest.java | 11 + .../apache/cassandra/metrics/CQLMetricsTest.java | 21 + .../metrics/CassandraMetricsRegistryTest.java | 107 +- .../metrics/ClientRequestMetricsTest.java | 33 +- .../ClientRequestRowAndColumnMetricsTest.java | 8 +- .../metrics/JmxVirtualTableMetricsTest.java | 336 ++++ .../cassandra/metrics/KeyspaceMetricsTest.java | 34 + .../cassandra/metrics/LatencyMetricsTest.java | 10 +- .../apache/cassandra/metrics/TableMetricsTest.java | 21 + .../cassandra/metrics/TrieMemtableMetricsTest.java | 25 +- .../org/apache/cassandra/net/HandshakeTest.java | 3 +- .../cassandra/net/OutboundConnectionsTest.java | 3 +- .../repair/ConcurrentIrWithPreviewFuzzTest.java | 2 +- .../cassandra/repair/FailingRepairFuzzTest.java | 1 + .../org/apache/cassandra/repair/FuzzTestBase.java | 206 +- .../org/apache/cassandra/repair/RepairJobTest.java | 4 +- .../RepairMessageVerbHandlerOutOfRangeTest.java | 2 +- .../messages/RepairMessageSerializationsTest.java | 31 +- .../cassandra/service/SerializationsTest.java | 14 +- .../async/StreamingInboundHandlerTest.java | 4 +- .../apache/cassandra/tcm/BootWithMetadataTest.java | 2 +- .../org/apache/cassandra/tcm/GetLogStateTest.java | 315 ++- .../org/apache/cassandra/tcm/LogStateTest.java | 13 +- .../tcm/compatibility/GossipHelperTest.java | 6 +- .../listeners/MetadataSnapshotListenerTest.java | 135 ++ .../cassandra/tcm/log/DistributedLogStateTest.java | 29 +- .../org/apache/cassandra/tcm/log/LocalLogTest.java | 68 +- .../tcm/log/LocalStorageLogStateTest.java | 24 +- .../apache/cassandra/tcm/log/LogStateTestBase.java | 236 +-- .../tcm/ownership/PlacementTransitionPlanTest.java | 251 +++ .../tcm/ownership/UniformRangePlacementTest.java | 68 +- .../InProgressSequenceCancellationTest.java | 18 +- .../tcm/sequences/ProgressBarrierTest.java | 6 +- .../cassandra/tcm/sequences/SequencesUtils.java | 7 +- .../apache/cassandra/triggers/TriggersTest.java | 98 +- .../cassandra/utils/AbstractTypeGenerators.java | 228 ++- .../apache/cassandra/utils/FBUtilitiesTest.java | 5 +- .../utils/asserts/SoftAssertionsWithLimit.java | 25 +- 541 files changed, 22805 insertions(+), 11337 deletions(-) create mode 100755 .build/ci/ci_parser.py create mode 100755 .build/ci/generate-ci-summary.sh copy .build/{check-code.sh => ci/generate-test-report.sh} (62%) create mode 100644 .build/ci/junit_helpers.py create mode 100644 .build/ci/logging.sh create mode 100755 .build/ci/logging_helper.py copy .build/{check-code.sh => ci/precommit_check.sh} (56%) copy .build/{check-code.sh => ci/requirements.txt} (61%) mode change 100755 => 100644 copy .build/{check-code.sh => docker/build-jars.sh} (62%) create mode 100644 src/java/org/apache/cassandra/cql3/ColumnsExpression.java delete mode 100644 src/java/org/apache/cassandra/cql3/MultiColumnRelation.java delete mode 100644 src/java/org/apache/cassandra/cql3/SingleColumnRelation.java delete mode 100644 src/java/org/apache/cassandra/cql3/TokenRelation.java create mode 100644 src/java/org/apache/cassandra/cql3/functions/ClusterMetadataFcts.java create mode 100644 src/java/org/apache/cassandra/cql3/restrictions/ClusteringElements.java create mode 100644 src/java/org/apache/cassandra/cql3/restrictions/LikePattern.java create mode 100644 src/java/org/apache/cassandra/cql3/restrictions/MergedRestriction.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/MultiColumnRestriction.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/PartitionKeySingleRestrictionSet.java create mode 100644 src/java/org/apache/cassandra/cql3/restrictions/SimpleRestriction.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/TermSlice.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/TokenFilter.java delete mode 100644 src/java/org/apache/cassandra/cql3/restrictions/TokenRestriction.java copy src/java/org/apache/cassandra/{tools/nodetool/SealPeriod.java => db/lifecycle/TransactionAlreadyCompletedException.java} (64%) create mode 100644 src/java/org/apache/cassandra/db/virtual/ClusterMetadataDirectoryTable.java create mode 100644 src/java/org/apache/cassandra/db/virtual/CollectionVirtualTableAdapter.java delete mode 100644 src/java/org/apache/cassandra/db/virtual/ThreadPoolsTable.java create mode 100644 src/java/org/apache/cassandra/db/virtual/model/Column.java copy src/java/org/apache/cassandra/{metrics/PaxosMetrics.java => db/virtual/model/CounterMetricRow.java} (56%) copy src/java/org/apache/cassandra/{metrics/BatchMetrics.java => db/virtual/model/GaugeMetricRow.java} (52%) create mode 100644 src/java/org/apache/cassandra/db/virtual/model/HistogramMetricRow.java create mode 100644 src/java/org/apache/cassandra/db/virtual/model/MeterMetricRow.java copy src/java/org/apache/cassandra/{metrics/PaxosMetrics.java => db/virtual/model/MetricGroupRow.java} (56%) create mode 100644 src/java/org/apache/cassandra/db/virtual/model/MetricRow.java create mode 100644 src/java/org/apache/cassandra/db/virtual/model/ThreadPoolRow.java create mode 100644 src/java/org/apache/cassandra/db/virtual/model/TimerMetricRow.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/CounterMetricRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/GaugeMetricRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/HistogramMetricRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/MeterMetricRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/MetricGroupRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/MetricRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/RowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/ThreadPoolRowWalker.java create mode 100644 src/java/org/apache/cassandra/db/virtual/walker/TimerMetricRowWalker.java copy src/java/org/apache/cassandra/service/paxos/cleanup/{PaxosFinishPrepareCleanup.java => PaxosRepairState.java} (58%) delete mode 100644 src/java/org/apache/cassandra/tcm/ownership/EntireRange.java rename src/java/org/apache/cassandra/tcm/ownership/{PlacementForRange.java => ReplicaGroups.java} (60%) rename src/java/org/apache/cassandra/tcm/transformations/{SealPeriod.java => TriggerSnapshot.java} (55%) copy src/java/org/apache/cassandra/{tools/nodetool/SealPeriod.java => triggers/TriggerDisabledException.java} (66%) create mode 100644 test/data/types-compatibility/4.0.json.gz create mode 100644 test/data/types-compatibility/4.1.json.gz create mode 100644 test/data/types-compatibility/5.0.json.gz create mode 100644 test/distributed/org/apache/cassandra/distributed/test/AbstractHintWindowTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/HintsMaxWindowTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/HintsPersistentWindowTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/guardrails/IntersectFilteringQueryTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/CMSCatchupTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/FetchLogFromPeers2Test.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/MetadataKeysTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/log/UnregisterTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/ring/CMSUrgentMessagesTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/streaming/StreamFailedWhileReceivingTest.java create mode 100644 test/distributed/org/apache/cassandra/distributed/test/tcm/RepairMetadataKeyspaceTest.java create mode 100644 test/distributed/org/apache/cassandra/fuzz/harry/examples/RepairBurnTest.java create mode 100644 test/distributed/org/apache/cassandra/fuzz/harry/integration/dsl/HistoryBuilderOverridesIntegrationTest.java copy src/java/org/apache/cassandra/tools/nodetool/SealPeriod.java => test/harry/main/org/apache/cassandra/harry/dsl/ArrayWrapper.java (57%) create mode 100644 test/harry/main/org/apache/cassandra/harry/dsl/OverridingBijection.java create mode 100644 test/harry/main/org/apache/cassandra/harry/dsl/OverridingCkGenerator.java create mode 100644 test/harry/main/org/apache/cassandra/harry/dsl/PartitionVisitStateImpl.java create mode 100644 test/harry/main/org/apache/cassandra/harry/dsl/ValueHelper.java rename src/java/org/apache/cassandra/tcm/Period.java => test/harry/main/org/apache/cassandra/harry/dsl/ValueOverrides.java (85%) create mode 100644 test/microbench/org/apache/cassandra/test/microbench/ReplicaGroupsBench.java create mode 100644 test/unit/org/apache/cassandra/cql3/RelationTest.java create mode 100644 test/unit/org/apache/cassandra/cql3/functions/ClusterMetadataFctsTest.java create mode 100644 test/unit/org/apache/cassandra/cql3/restrictions/ClusteringElementsTest.java create mode 100644 test/unit/org/apache/cassandra/db/guardrails/GuardrailSaiFrozenTermSizeTest.java create mode 100644 test/unit/org/apache/cassandra/db/guardrails/GuardrailSaiStringTermSizeTest.java create mode 100644 test/unit/org/apache/cassandra/db/guardrails/GuardrailSaiVectorTermSizeTest.java create mode 100644 test/unit/org/apache/cassandra/db/guardrails/ValueThresholdTester.java create mode 100644 test/unit/org/apache/cassandra/db/virtual/CollectionVirtualTableAdapterTest.java create mode 100644 test/unit/org/apache/cassandra/db/virtual/model/CollectionEntry.java create mode 100644 test/unit/org/apache/cassandra/db/virtual/model/CollectionEntryTestRow.java copy src/java/org/apache/cassandra/gms/IGossiper.java => test/unit/org/apache/cassandra/db/virtual/model/PartitionEntryTestRow.java (52%) create mode 100644 test/unit/org/apache/cassandra/db/virtual/walker/CollectionEntryTestRowWalker.java create mode 100644 test/unit/org/apache/cassandra/db/virtual/walker/PartitionEntryTestRowWalker.java create mode 100644 test/unit/org/apache/cassandra/hints/HintsPendingTableTest.java create mode 100644 test/unit/org/apache/cassandra/metrics/JmxVirtualTableMetricsTest.java create mode 100644 test/unit/org/apache/cassandra/tcm/listeners/MetadataSnapshotListenerTest.java create mode 100644 test/unit/org/apache/cassandra/tcm/ownership/PlacementTransitionPlanTest.java rename src/java/org/apache/cassandra/tools/nodetool/SealPeriod.java => test/unit/org/apache/cassandra/utils/asserts/SoftAssertionsWithLimit.java (59%) --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@cassandra.apache.org For additional commands, e-mail: commits-h...@cassandra.apache.org