mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-5.0' into trunk
This commit is contained in:
commit
01d8cbdd1e
|
|
@ -5,6 +5,7 @@
|
|||
* Add the ability to disable bulk loading of SSTables (CASSANDRA-18781)
|
||||
* Clean up obsolete functions and simplify cql_version handling in cqlsh (CASSANDRA-18787)
|
||||
Merged from 5.0:
|
||||
* Clone EndpointState before sending GossipShutdown message (CASSANDRA-19115)
|
||||
* SAI indexes are marked queryable during truncation (CASSANDRA-19032)
|
||||
* Enable Direct-IO feature for CommitLog files using Java native API's. (CASSANDRA-18464)
|
||||
* SAI fixes for composite partitions, and static and non-static rows intersections (CASSANDRA-19034)
|
||||
|
|
|
|||
|
|
@ -1800,7 +1800,9 @@ public class Gossiper implements IFailureDetectionEventListener, GossiperMBean,
|
|||
|
||||
addLocalApplicationState(ApplicationState.STATUS_WITH_PORT, StorageService.instance.valueFactory.shutdown(true));
|
||||
addLocalApplicationState(ApplicationState.STATUS, StorageService.instance.valueFactory.shutdown(true));
|
||||
Message<GossipShutdown> message = Message.out(Verb.GOSSIP_SHUTDOWN, new GossipShutdown(mystate));
|
||||
// clone endpointstate to avoid it changing between serializedSize and serialize calls
|
||||
EndpointState clone = new EndpointState(mystate);
|
||||
Message<GossipShutdown> message = Message.out(Verb.GOSSIP_SHUTDOWN, new GossipShutdown(clone));
|
||||
for (InetAddressAndPort ep : liveEndpoints)
|
||||
MessagingService.instance().send(message, ep);
|
||||
Uninterruptibles.sleepUninterruptibly(SHUTDOWN_ANNOUNCE_DELAY_IN_MS.getInt(), TimeUnit.MILLISECONDS);
|
||||
|
|
|
|||
Loading…
Reference in New Issue