Github user ifesdjeen closed the pull request at:
https://github.com/apache/cassandra/pull/269
---
-
To unsubscribe, e-mail: pr-unsubscr...@cassandra.apache.org
For additional commands, e-mail: pr-h...@cassandra.apache.org
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r220455656
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -424,62 +440,58 @@ else if (useStrictConsistency)
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r220336800
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -424,62 +440,58 @@ else if (useStrictConsistency)
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488654
--- Diff: src/java/org/apache/cassandra/service/RangeRelocator.java ---
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488682
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -338,165 +386,152 @@ else if (useStrictConsistency)
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488550
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -446,16 +447,14 @@ else if (useStrictConsistency)
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488342
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -436,6 +436,7 @@ else if (useStrictConsistency)
Set
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219488307
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -265,10 +318,11 @@ public void addRanges(String keyspaceName,
ReplicaCollection
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219410357
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -446,16 +447,14 @@ else if (useStrictConsistency)
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219281323
--- Diff: src/java/org/apache/cassandra/service/RangeRelocator.java ---
@@ -0,0 +1,326 @@
+/*
+ * Licensed to the Apache Software Foundation
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219279196
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -473,7 +472,7 @@ else if (useStrictConsistency)
}
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219278292
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -446,16 +447,14 @@ else if (useStrictConsistency)
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219277526
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -436,6 +436,7 @@ else if (useStrictConsistency)
Set
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r219271571
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -265,10 +318,11 @@ public void addRanges(String keyspaceName,
ReplicaCollection
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218554481
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -328,7 +356,6 @@ else if (useStrictConsistency)
* Get a map of all
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218547456
--- Diff: src/java/org/apache/cassandra/locator/RangesAtEndpoint.java ---
@@ -302,6 +303,11 @@ public static RangesAtEndpoint
toDummyList(Collection>
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218547170
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -600,39 +628,38 @@ public StreamResultFuture fetchAsync()
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218470693
--- Diff: src/java/org/apache/cassandra/streaming/StreamPlan.java ---
@@ -70,6 +70,16 @@ public StreamPlan(StreamOperation streamOperation, int
Github user aweisberg commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218462328
--- Diff: src/java/org/apache/cassandra/streaming/StreamPlan.java ---
@@ -70,6 +70,16 @@ public StreamPlan(StreamOperation streamOperation, int
Github user ifesdjeen commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218432647
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -87,8 +85,8 @@
private final InetAddressAndPort address;
/*
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218388108
--- Diff: src/java/org/apache/cassandra/dht/StreamStateStore.java ---
@@ -54,8 +56,10 @@ public RangesAtEndpoint getAvailableRanges(String
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218383166
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -337,165 +364,167 @@ else if (useStrictConsistency)
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218387370
--- Diff: src/java/org/apache/cassandra/streaming/StreamPlan.java ---
@@ -70,6 +70,16 @@ public StreamPlan(StreamOperation streamOperation, int
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218387701
--- Diff: src/java/org/apache/cassandra/db/SystemKeyspace.java ---
@@ -1288,24 +1288,25 @@ public static synchronized void
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218383055
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -337,165 +364,167 @@ else if (useStrictConsistency)
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218382891
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -87,8 +85,8 @@
private final InetAddressAndPort address;
/*
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218382719
--- Diff: src/java/org/apache/cassandra/dht/RangeStreamer.java ---
@@ -328,7 +356,6 @@ else if (useStrictConsistency)
* Get a map of all
Github user belliottsmith commented on a diff in the pull request:
https://github.com/apache/cassandra/pull/269#discussion_r218371266
--- Diff: test/unit/org/apache/cassandra/dht/BootStrapperTest.java ---
@@ -125,21 +125,19 @@ public boolean isAlive(InetAddressAndPort ep)
GitHub user ifesdjeen opened a pull request:
https://github.com/apache/cassandra/pull/269
Review tr range movements
CASSANDRA-14756
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/ifesdjeen/cassandra review-tr-range-movements
29 matches
Mail list logo
