You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by br...@apache.org on 2015/04/14 19:46:10 UTC
[2/4] cassandra git commit: Fix failed bootstrap/replace attempts
being persisted in system.peers
Fix failed bootstrap/replace attempts being persisted in system.peers
Patch by brandonwilliams, reviewed by slebresne for CASSANDRA-9180
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/cba1b68d
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/cba1b68d
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/cba1b68d
Branch: refs/heads/trunk
Commit: cba1b68dbececb2aba500d56059e99bdab058b10
Parents: f59df28
Author: Brandon Williams <br...@apache.org>
Authored: Tue Apr 14 12:19:53 2015 -0500
Committer: Brandon Williams <br...@apache.org>
Committed: Tue Apr 14 12:45:23 2015 -0500
----------------------------------------------------------------------
CHANGES.txt | 2 +
.../cassandra/service/StorageService.java | 57 ++++++++++----------
2 files changed, 32 insertions(+), 27 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/cba1b68d/CHANGES.txt
----------------------------------------------------------------------
diff --git a/CHANGES.txt b/CHANGES.txt
index d64ebc5..dfd5649 100644
--- a/CHANGES.txt
+++ b/CHANGES.txt
@@ -75,6 +75,8 @@
* Use stdout for progress and stats in sstableloader (CASSANDRA-8982)
* Correctly identify 2i datadir from older versions (CASSANDRA-9116)
Merged from 2.0:
+2.0.15:
+ * Fix failed bootstrap/replace attempts being persisted in system.peers (CASSANDRA-9180)
* Flush system.IndexInfo after marking index built (CASSANDRA-9128)
* Fix updates to min/max_compaction_threshold through cassandra-cli
(CASSANDRA-8102)
http://git-wip-us.apache.org/repos/asf/cassandra/blob/cba1b68d/src/java/org/apache/cassandra/service/StorageService.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/service/StorageService.java b/src/java/org/apache/cassandra/service/StorageService.java
index a5fa563..c212d0d 100644
--- a/src/java/org/apache/cassandra/service/StorageService.java
+++ b/src/java/org/apache/cassandra/service/StorageService.java
@@ -1479,34 +1479,37 @@ public class StorageService extends NotificationBroadcasterSupport implements IE
return;
}
- switch (state)
+ if (getTokenMetadata().isMember(endpoint))
{
- case RELEASE_VERSION:
- SystemKeyspace.updatePeerInfo(endpoint, "release_version", value.value);
- break;
- case DC:
- SystemKeyspace.updatePeerInfo(endpoint, "data_center", value.value);
- break;
- case RACK:
- SystemKeyspace.updatePeerInfo(endpoint, "rack", value.value);
- break;
- case RPC_ADDRESS:
- try
- {
- SystemKeyspace.updatePeerInfo(endpoint, "rpc_address", InetAddress.getByName(value.value));
- }
- catch (UnknownHostException e)
- {
- throw new RuntimeException(e);
- }
- break;
- case SCHEMA:
- SystemKeyspace.updatePeerInfo(endpoint, "schema_version", UUID.fromString(value.value));
- MigrationManager.instance.scheduleSchemaPull(endpoint, epState);
- break;
- case HOST_ID:
- SystemKeyspace.updatePeerInfo(endpoint, "host_id", UUID.fromString(value.value));
- break;
+ switch (state)
+ {
+ case RELEASE_VERSION:
+ SystemKeyspace.updatePeerInfo(endpoint, "release_version", value.value);
+ break;
+ case DC:
+ SystemKeyspace.updatePeerInfo(endpoint, "data_center", value.value);
+ break;
+ case RACK:
+ SystemKeyspace.updatePeerInfo(endpoint, "rack", value.value);
+ break;
+ case RPC_ADDRESS:
+ try
+ {
+ SystemKeyspace.updatePeerInfo(endpoint, "rpc_address", InetAddress.getByName(value.value));
+ }
+ catch (UnknownHostException e)
+ {
+ throw new RuntimeException(e);
+ }
+ break;
+ case SCHEMA:
+ SystemKeyspace.updatePeerInfo(endpoint, "schema_version", UUID.fromString(value.value));
+ MigrationManager.instance.scheduleSchemaPull(endpoint, epState);
+ break;
+ case HOST_ID:
+ SystemKeyspace.updatePeerInfo(endpoint, "host_id", UUID.fromString(value.value));
+ break;
+ }
}
}
}