natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Catch exception on bootstrap resume and init native transport 

Patch by Berenguer Blasi, reviewed by brandonwilliams for CASSANDRA-15863
This commit is contained in:
Bereng 2020-06-10 12:34:34 +02:00 committed by Brandon Williams
parent 408f969f3c
commit 4f50a6712a
3 changed files with 23 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -2,6 +2,7 @@
* Fix CQL formatting of read command restrictions for slow query log (CASSANDRA-15503)
* Allow sstableloader to use SSL on the native port (CASSANDRA-14904)
Merged from 3.0:
* Catch exception on bootstrap resume and init native transport (CASSANDRA-15863)
* Fix replica-side filtering returning stale data with CL > ONE (CASSANDRA-8272, CASSANDRA-8273)
* Fix duplicated row on 2.x upgrades when multi-rows range tombstones interact with collection ones (CASSANDRA-15805)
* Rely on snapshotted session infos on StreamResultFuture.maybeComplete to avoid race conditions (CASSANDRA-15667)

3
src/java/org/apache/cassandra/service/CassandraDaemon.java
View File

@ -450,7 +450,8 @@ public class CassandraDaemon
public void initializeNativeTransport()
{
// Native transport
nativeTransportService = new NativeTransportService();
if (nativeTransportService == null)
nativeTransportService = new NativeTransportService();
}
/*

32
src/java/org/apache/cassandra/service/StorageService.java
View File

@ -1592,22 +1592,30 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
@Override
public void onSuccess(StreamState streamState)
{
bootstrapFinished();
// start participating in the ring.
// pretend we are in survey mode so we can use joinRing() here
if (isSurveyMode)
try
{
logger.info("Startup complete, but write survey mode is active, not becoming an active ring member. Use JMX (StorageService->joinRing()) to finalize ring joining.");
bootstrapFinished();
if (isSurveyMode)
{
logger.info("Startup complete, but write survey mode is active, not becoming an active ring member. Use JMX (StorageService->joinRing()) to finalize ring joining.");
}
else
{
isSurveyMode = false;
progressSupport.progress("bootstrap", ProgressEvent.createNotification("Joining ring..."));
finishJoiningRing(true, bootstrapTokens);
}
progressSupport.progress("bootstrap", new ProgressEvent(ProgressEventType.COMPLETE, 1, 1, "Resume bootstrap complete"));
if (!isNativeTransportRunning())
daemon.initializeNativeTransport();
daemon.start();
logger.info("Resume complete");
}
else
catch(Exception e)
{
isSurveyMode = false;
progressSupport.progress("bootstrap", ProgressEvent.createNotification("Joining ring..."));
finishJoiningRing(true, bootstrapTokens);
onFailure(e);
throw e;
}
progressSupport.progress("bootstrap", new ProgressEvent(ProgressEventType.COMPLETE, 1, 1, "Resume bootstrap complete"));
daemon.start();
logger.info("Resume complete");
}
@Override